将debezium任务提交到confluent connect时创建数据库历史记录主题失败

eqzww0vc  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(375)

尝试将debezium任务提交到confluent时引发以下异常。尝试手动创建主题,然后提交任务,但仍出现相同的异常

org.apache.kafka.connect.errors.ConnectException: Creation of database history topic failed, please create the topic manually
at io.debezium.relational.history.KafkaDatabaseHistory.initializeStorage(KafkaDatabaseHistory.java:349)
at io.debezium.connector.mysql.MySqlSchema.intializeHistoryStorage(MySqlSchema.java:283)
at io.debezium.connector.mysql.MySqlTaskContext.initializeHistoryStorage(MySqlTaskContext.java:192)
at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:126)
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:45)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:157)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:170)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:214)
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)

Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support DESCRIBE_CONFIGS
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)

debezium版本-0.7.5 kafka-0.10.0 confluent-2.11

tpgth1q7

tpgth1q71#

不幸的是,debezium使用了kafka 0.10.0中没有的管理api。

相关问题