-
Task
-
Resolution: Done
-
Blocker
-
0.2.1
-
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)
- is related to
-
DBZ-62 Upgrade to Kafka 0.10
- Closed