i am getting frequently following error in log:
Additional Details:
DCP Client - 0.37.0
kafka-connect-couchbase - 4.1.6
Mode : distributed with multiple pod
Logs:
[2023-02-09 06:54:19,537] ERROR WorkerSourceTask{id=data_consistency_internal-9} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:195)
org.apache.kafka.connect.errors.ConnectException: java.lang.IllegalStateException: Tried to add duplicate channel: DcpChannel{address=couchbase-att-prod-node4.prod1:11207}
at com.couchbase.connect.kafka.CouchbaseSourceTask.checkErrorQueue(CouchbaseSourceTask.java:175)
at com.couchbase.connect.kafka.CouchbaseSourceTask.poll(CouchbaseSourceTask.java:136)
at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:305)
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:249)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:188)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:243)
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)
Caused by: java.lang.IllegalStateException: Tried to add duplicate channel: DcpChannel{address=couchbase-att-prod-node4.prod1:11207}
at com.couchbase.client.dcp.conductor.Conductor.add(Conductor.java:298)
at java.base/java.util.ArrayList.forEach(ArrayList.java:1541)
at com.couchbase.client.dcp.conductor.Conductor.connect(Conductor.java:115)
at com.couchbase.client.dcp.Client.connect(Client.java:460)
at com.couchbase.connect.kafka.CouchbaseReader.run(CouchbaseReader.java:165)