Kafka connector:AvroConverter exception

2016-04-11 Thread victory_zgh
Hi, In the process of kafka sink connetor test, after I launched connect-standalone and ran kafka-avro-console-producer command, I typed {"f1":"value1"} in the console according to the demo mentioned in kafka connector document . But connect-standalone terminal prints such excpetion 2016-04-1

kafka-connector sink task flush() interval

2016-04-08 Thread victory_zgh
Hi, Recently, I am working on kafka connector implement. According to the connector sink task document, the connect platform invoke flush method periodically, But the doc does not metition the flush interval. I don't know the flush interval default value or Where we can set this interval?? Be