类似的问题与KafkaFlume表从Kafka的主题
我在sqlserver端更改了密钥，它给出了以下错误
[2019-04-30 15:04:16,946]error workersinktask{id=jdbc\u sink\u ddfsc10-0}任务引发了未捕获且不可恢复的异常（org.apache.kafka.connect.runtime.workertask:177)org.apache.kafka.common.errors.wakeupexception位于org.apache.kafka.clients.consumer.internals.consumernetworkclient.maybetriggerwakeup（consumernetworkclient）。java:487)在org.apache.kafka.clients.consumer.internals.consumernetworkclient.poll（consumernetworkclient。java:278)在org.apache.kafka.clients.consumer.internals.consumernetworkclient.poll（consumernetworkclient。java:236)在org.apache.kafka.clients.consumer.internals.consumernetworkclient.poll（consumernetworkclient。java:215)在org.apache.kafka.clients.consumer.internals.consumercoordinator.commitofsetssync（consumercoordinator。java:662)在org.apache.kafka.clients.consumer.kafkaconsumer.commitsync（kafkaconsumer。java:1425)在org.apache.kafka.clients.consumer.kafkaconsumer.commitsync（kafkaconsumer。java:1384)在org.apache.kafka.connect.runtime.workersinktask.docommitsync（workersinktask）。java:332)在org.apache.kafka.connect.runtime.workersinktask.docommit（workersinktask。java:360)位于org.apache.kafka.connect.runtime.workersinktask.commitofsets（workersinktask。java:431)在org.apache.kafka.connect.runtime.workersinktask.closepartitions（workersinktask。java:590)在org.apache.kafka.connect.runtime.workersinktask.execute（workersinktask。java:196)在org.apache.kafka.connect.runtime.workertask.dorun（workertask。java:175)在org.apache.kafka.connect.runtime.workertask.run（workertask。java:219)在java.util.concurrent.executors$runnableadapter.call（executors。java:511)在java.util.concurrent.futuretask.run（futuretask。java:266)位于java.util.concurrent.threadpoolexecutor.runworker（threadpoolexecutor。java:1142)在java.util.concurrent.threadpoolexecutor$worker.run（threadpoolexecutor。java:617)在java.lang.thread.run（线程。java:748)