Hi,I have a question。When using connect-distributed, I start some connectors those push the data to ES from kafka. But there are many errors in the log,why are these errors and how to solve the problem?
Thinks! [2017-01-09 16:24:30,645] INFO Sink task WorkerSinkTask{id=es4kafa1112-0} finished initialization and start (org.apache.kafka.connect.runtime.WorkerSinkTask:208) [2017-01-09 16:24:30,668] ERROR Task es4kafa1113-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142) org.apache.kafka.common.errors.WakeupException at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.maybeTrigg erWakeup(ConsumerNetworkClient.java:367) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll (ConsumerNetworkClient.java:361) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(Consu merNetworkClient.java:224) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(Consu merNetworkClient.java:192) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(Consu merNetworkClient.java:163) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.commitOffset sSync(ConsumerCoordinator.java:426) at org.apache.kafka.clients.consumer.KafkaConsumer.commitSync(KafkaConsumer.jav a:1059) at org.apache.kafka.connect.runtime.WorkerSinkTask.doCommitSync(WorkerSinkTask. java:244) at org.apache.kafka.connect.runtime.WorkerSinkTask.doCommit(WorkerSinkTask.java :263) at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask .java:304) at org.apache.kafka.connect.runtime.WorkerSinkTask.closePartitions(WorkerSinkTa sk.java:432) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java: 146) 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:11 42) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:6 17) at java.lang.Thread.run(Thread.java:745) [2017-01-09 16:24:30,672] ERROR Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:143) [2017-01-09 16:24:30,747] INFO Discovered coordinator idap-agent-179.idap.com:6667 (id: 2147482645 rack: null) for group connect-es4kafa1112. (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:505) [2017-01-09 16:24:30,748] INFO Revoking previously assigned partitions [] for group connect-es4kafa1112 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:292) [2017-01-09 16:24:30,748] INFO (Re-)joining group connect-es4kafa1112 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:326) [2017-01-09 16:24:30,840] INFO Successfully joined group connect-es4kafa1112 with generation 1 (org.apache.kafka.clients.consumer.internals.AbstractCoordinator:434)
smime.p7s
Description: S/MIME cryptographic signature