Hi,
I tried executing the following,
bin/connect-standalone.sh config/connect-standalone.properties
config/connect-file-source.properties config/connect-console-sink.properties
I created a file text.txt in kafka directory but get the error,
ERROR Failed to flush WorkerSourceTask{id=local-file-source-0}, timed out
while waiting for producer to flush outstanding messages, 1 left
({ProducerRecord(topic=connect-test, partition=null, key=[B@71bb594d,
value=[B@7f7ca90a=ProducerRecord(topic=connect-test, partition=null,
key=[B@71bb594d, value=[B@7f7ca90a})
(org.apache.kafka.connect.runtime.WorkerSourceTask:237)
[2016-01-12 11:43:51,948] ERROR Failed to commit offsets for
WorkerSourceTask{id=local-file-source-0}
(org.apache.kafka.connect.runtime.SourceTaskOffsetCommitter:112)
Is any other configuration required?
Thanks,
Shiti
