-
Bug
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
False
-
kafka version: "2.1.0-cdh6.2.1"
debezium version: "1.9.0.Alpha2"
when I post a new connectors api,this error shows:
java.lang.NoSuchMethodError: org.apache.kafka.clients.admin.NewTopic.<init>(Ljava/lang/String;Ljava/util/Optional;Ljava/util/Optional;)V at io.debezium.relational.history.KafkaDatabaseHistory.initializeStorage(KafkaDatabaseHistory.java:512) at io.debezium.relational.HistorizedRelationalDatabaseSchema.initializeStorage(HistorizedRelationalDatabaseSchema.java:81) at io.debezium.connector.oracle.OracleDatabaseSchema.initializeStorage(OracleDatabaseSchema.java:94) at io.debezium.connector.oracle.OracleConnectorTask.validateAndLoadDatabaseHistory(OracleConnectorTask.java:165) at io.debezium.connector.oracle.OracleConnectorTask.start(OracleConnectorTask.java:71) at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:130) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:198) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219) 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:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)
but I am test Successful in the version:3.1.0(kafka)
- is caused by
-
DBZ-4547 MySQL history topic creation needs DESCRIBE_CONFIGS at the Cluster level
- Closed