Rollulus Rouloul
Rollulus Rouloul
Column names are less restricted than Go struct field names, which should be proper Go identifiers. Hence, column names cannot be translated directly into field names. This commit tries to...
Apache FTPClient's retrieveFile silently and indefinitely hangs on failed connection in active mode
At least, that's what I've come to believe.
`[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 poll (com.eneco.trading.kafka.connect.ftp.source.FtpSourcePoller) [2017-04-18 01:19:18,710] INFO connect...
I developed this thing in standalone mode. In distributed mode there is some latency requesting offsets from the store. I didn't know that. The offset store can hence be more...
Files that are `tailed` are only allowed to grow, only the grown part is output. Bytes that were previously being output are not allowed to change. E.g.: ``` poll#1: aaaaaa...
Provide a pure test stage that doesn't require topics or .properties
Might simplify life?