Catch timeout exception during connect

[rollulus]

[2017-04-18 01:20:18,883] INFO start FtpSourceConnector 0.1.6 (201c06c5f2fff131f7b5cc2fb1a5858c37db2e7f), committed at 20.03.2017 @ 09:11:31 UTC, built at 20.03.2017 @ 15:27:35 UTC (com.eneco.trading.kafka.connect.ftp.source.FtpSourceConnector)

[2017-04-18 01:19:18,710] INFO connect pointconnect.commodities.thomson<redacted>.com:None (com.eneco.trading.kafka.connect.ftp.source.FtpMonitor)
[2017-04-18 01:19:48,808] ERROR Task <redacted>-source-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask)
java.io.IOException: Timed out waiting for initial connect reply
	at org.apache.commons.net.ftp.FTP._connectAction_(FTP.java:411)
	at org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:966)
	at org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:954)
	at org.apache.commons.net.SocketClient.connect(SocketClient.java:189)
	at org.apache.commons.net.SocketClient.connect(SocketClient.java:209)
	at org.apache.commons.net.SocketClient.connect(SocketClient.java:306)
	at com.eneco.trading.kafka.connect.ftp.source.FtpMonitor.connectFtp(FtpMonitor.scala:141)
	at com.eneco.trading.kafka.connect.ftp.source.FtpMonitor.poll(FtpMonitor.scala:164)
	at com.eneco.trading.kafka.connect.ftp.source.FtpSourcePoller.fetchRecords(FtpSourceTask.scala:57)
	at com.eneco.trading.kafka.connect.ftp.source.FtpSourcePoller.poll(FtpSourceTask.scala:48)
	at com.eneco.trading.kafka.connect.ftp.source.FtpSourceTask.poll(FtpSourceTask.scala:98)
	at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:155)
	at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
	at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.net.SocketTimeoutException: Read timed out
	at java.net.SocketInputStream.socketRead0(Native Method)
	at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
	at java.net.SocketInputStream.read(SocketInputStream.java:170)
	at java.net.SocketInputStream.read(SocketInputStream.java:141)
	at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
	at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
	at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)
	at java.io.InputStreamReader.read(InputStreamReader.java:184)
	at java.io.BufferedReader.fill(BufferedReader.java:161)
	at java.io.BufferedReader.read(BufferedReader.java:182)
	at org.apache.commons.net.io.CRLFLineReader.readLine(CRLFLineReader.java:58)
	at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:313)
	at org.apache.commons.net.ftp.FTP.__getReply(FTP.java:292)
	at org.apache.commons.net.ftp.FTP._connectAction_(FTP.java:405)
	... 18 more
[2017-04-18 01:19:48,811] ERROR Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask)
[2017-04-18 01:20:09,391] INFO Kafka Connect stopping (org.apache.kafka.connect.runtime.Connect)