Uploaded image for project: 'Kafka Connector'
  1. Kafka Connector
  2. KAFKA-347

NoClassDefFoundError For CodecRegistryHelper

    XMLWordPrintableJSON

Details

    • Icon: Question Question
    • Resolution: Done
    • Icon: Unknown Unknown
    • None
    • None
    • None
    • None

    Description

      We are getting following error for both sink and source connector . we are using lastest version of connector 1.8.1

       

      Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: org/bson/internal/CodecRegistryHelper (org.apache.kafka.connect.runtime.WorkerSinkTask:616)
      java.lang.NoClassDefFoundError: org/bson/internal/CodecRegistryHelper
      at com.mongodb.client.internal.MongoClientImpl.<init>(MongoClientImpl.java:73)
      at com.mongodb.client.internal.MongoClientImpl.<init>(MongoClientImpl.java:63)
      at com.mongodb.client.MongoClients.create(MongoClients.java:108)
      at com.mongodb.kafka.connect.sink.MongoSinkTask.getMongoClient(MongoSinkTask.java:193)
      at com.mongodb.kafka.connect.sink.MongoSinkTask.bulkWriteBatch(MongoSinkTask.java:229)
      at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
      at com.mongodb.kafka.connect.sink.MongoSinkTask.put(MongoSinkTask.java:131)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:584)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:334)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:235)
      at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:204)
      at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:201)
      at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:256)
      at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
      at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
      at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
      at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
      at java.base/java.lang.Thread.run(Thread.java:829) 

       

      Attachments

        Activity

          People

            ross@mongodb.com Ross Lawley
            krishna.agarwal@tui.co.uk Krishna Agrawal
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: