3/10 14:29:03,766
Kafka Consumer log:
Task dp-infobright-connector-dptask_305.testdb.record_500w_0-0 threw an uncaught and unrecoverable exception   [pool-1-thread-2][WorkerTask.java:142]
org.apache.kafka.common.KafkaException: Record for partition dptask_305.testdb.record_500w_0-0 at offset 193333 is invalid, cause: Record is corrupt (stored crc = 1486557982, computed crc = 344473972)
at org.apache.kafka.clients.consumer.internals.Fetcher.parseRecord(Fetcher.java:743)
at org.apache.kafka.clients.consumer.internals.Fetcher.parseFetchedData(Fetcher.java:682)
at org.apache.kafka.clients.consumer.internals.Fetcher.fetchedRecords(Fetcher.java:425)
at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1045)
at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979)
at org.apache.kafka.connect.runtime.WorkerSinkTask.pollConsumer(WorkerSinkTask.java:317)
at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:235)
at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:172)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:143)
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)

Kafka log:

[2017-03-10 06:26:43,576] INFO [Group Metadata Manager on Broker 1002]: Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)
[2017-03-10 06:29:03,766] INFO [GroupCoordinator 1002]: Preparing to restabilize group connect-dp-infobright-connector-dptask_305.testdb.record_500w_0 with old generation 1 (kafka.coordinator.GroupCoordinator)
[2017-03-10 06:29:03,766] INFO [GroupCoordinator 1002]: Group connect-dp-infobright-connector-dptask_305.testdb.record_500w_0 with generation 2 is now empty (kafka.coordinator.GroupCoordinator)
[2017-03-10 06:36:43,576] INFO [Group Metadata Manager on Broker 1002]: Removed 0 expired offsets in 1 milliseconds. (kafka.coordinator.GroupMetadataManager)