Details
-
Question
-
Resolution: Done
-
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) |