Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-1270

Exception when starting the connector on Kafka Broker 0.10.1.0

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Minor Minor
    • 0.10.0.Beta2
    • 0.9.3.Final
    • mysql-connector
    • 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.

              Unassigned Unassigned
              stathis.souris@gmail.com Stathis Souris (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: