-
Task
-
Resolution: Done
-
Blocker
-
0.2.1
-
None
-
debezium 0.2.1 in a standalone kafka connector (confluent 3.0, kafka 0.10)
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
-