-
Bug
-
Resolution: Not a Bug
-
Blocker
-
Camel-K-M4
-
None
-
False
-
False
-
%
-
Undefined
-
Camel Kafka Connector
-
I created a jdbcsink connector with following config:
{{ class: org.apache.camel.kafkaconnector.jdbc.CamelJdbcSinkConnector}}
{{ config:}}
{{ value.converter: org.apache.kafka.connect.storage.StringConverter}}
{{ topics: org.apache.camel.kafkaconnector.jdbc.sink.CamelSinkJDBCITCase}}
{{ camel.component.jdbc.dataSource.user: ckc}}
{{ camel.component.jdbc.dataSource: '#class:org.postgresql.ds.PGSimpleDataSource'}}
{{ camel.component.jdbc.dataSource.url: 'jdbc:postgresql://postgresql:5432/testDB'}}
{{ camel.sink.endpoint.useHeadersAsParameters: true}}
{{ key.converter: org.apache.kafka.connect.storage.StringConverter}}
{{ camel.sink.path.dataSourceName: someName}}
{{ camel.component.jdbc.dataSource.password: ckcDevel123}}
And I got the following trace:
java.lang.NoSuchMethodError: 'org.apache.kafka.connect.sink.ErrantRecordReporter org.apache.kafka.connect.sink.SinkTaskContext.errantRecordReporter()'\n\tat org.apache.camel.kafkaconnector.CamelSinkTask.start(CamelSinkTask.java:76)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:305)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:193)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:184)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:234)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:834)\n
This happens with version "0.7.1.fuse-800001-redhat-00001" but not the upstream connectors.
This is only an issue for AMQ Streams 1.6.2 on OCP.