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

NoSuchMethodError KafkaConsumer.subscribe(Ljava/util/List;) with kafka 0.10

XMLWordPrintable

    • Icon: Task Task
    • Resolution: Done
    • Icon: Blocker Blocker
    • 0.3
    • 0.2.1
    • mysql-connector
    • None

      I'm getting following incompatibility error running debezium 0.2.1 on in a standalone kafka connector (confluent 3.0, kafka 0.10).
      What could be wrong?

      > [~/dw/confluent-3.0.0] $ ./bin/connect-standalone etc/schema-registry/connect-avro-standalone.properties  shipment-connector.properties
      [2016-06-22 03:05:30,426] ERROR Task shipment-connector-0 threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:142)
      java.lang.NoSuchMethodError: org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(Ljava/util/List;)V
              at io.debezium.relational.history.KafkaDatabaseHistory.recoverRecords(KafkaDatabaseHistory.java:159)
              at io.debezium.relational.history.AbstractDatabaseHistory.recover(AbstractDatabaseHistory.java:50)
              at io.debezium.connector.mysql.MySqlSchema.loadHistory(MySqlSchema.java:251)
              at io.debezium.connector.mysql.MySqlTaskContext.loadHistory(MySqlTaskContext.java:98)
              at io.debezium.connector.mysql.MySqlConnectorTask.start(MySqlConnectorTask.java:78)
              at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:137)
              at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
              at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
              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)
      

            rhauch Randall Hauch (Inactive)
            bhupi.iit Bhupinder Garg (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

              Created:
              Updated:
              Resolved: