Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-15643

CKC jdbc connector NoSuchMethodError errantRecordReporter()

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Not a Bug
    • Icon: Blocker Blocker
    • Camel-K-M4
    • Camel-K-M4
    • Camel Kafka Connector
    • 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.

            opiske Otavio Piske
            mmuzikar Martin Muzikar
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: