-
Bug
-
Resolution: Done
-
Minor
-
0.9.3.Final
-
None
Getting an exception when trying to start the Debezium connector.
Stack:
- Debezium 0.9.3.Final
- Kafka 0.10.1.0
exception:
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) at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32) at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:104) at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:225) at io.debezium.relational.history.KafkaDatabaseHistory.getKafkaBrokerConfig(KafkaDatabaseHistory.java:361) at io.debezium.relational.history.KafkaDatabaseHistory.initializeStorage(KafkaDatabaseHistory.java:338) ... 12 more Caused by: org.apache.kafka.common.errors.UnsupportedVersionException: The broker does not support DESCRIBE_CONFIGS
The problem still persists even after the creation of the database history topic.
The problem is in the Kafka broker version that I'm using which is `0.10.1.0`, that does not support the `DESCRIBE_CONFIGS` command.