Подобный вид вопроса с кафкой-мойкой для стола из темы кафки
Я изменил ключи на стороне сервера SQL, и это дает мне ошибку ниже
[2019-04-30 15: 04: 16,946] ОШИБКА WorkerSinkTask {id = jdbc_sink_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.commitOffsetsSync (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.commitOffsets (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)
at java.lang.Thread.run (Thread.java:748)