we are getting follwing error for both sink and source connectors. we are using 1.8.1 mongo connect. we dont know if more tools needs to be installed or any jars needs to be added.
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)