Hi Team
I am running kafka couchbase connector and I am facing below issue. I am not sure in what scenario couchbase will throw 400 bad request.
Logs -:
06:51:10.192 [nioEventLoopGroup-3-1] WARN c.c.c.d.c.HttpStreamingConfigProvider - Could not get config from Node, trying next in list.
com.couchbase.client.core.CouchbaseException: Unknown error code during connect: 400 Bad Request
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:81) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:39) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:312) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:286) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1304) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:921) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:135) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:646) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:546) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:460) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:131) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
06:51:10.210 [nioEventLoopGroup-3-2] WARN c.c.c.d.c.HttpStreamingConfigProvider - Could not get config from Node, trying next in list.
com.couchbase.client.core.CouchbaseException: Unknown error code during connect: 400 Bad Request
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:81) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:39) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:312) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:286) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1304) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:921) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:135) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:646) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:546) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:460) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:131) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
06:51:10.224 [nioEventLoopGroup-3-3] WARN c.c.c.d.c.HttpStreamingConfigProvider - Could not get config from Node, trying next in list.
com.couchbase.client.core.CouchbaseException: Unknown error code during connect: 400 Bad Request
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:81) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:39) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:312) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:286) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1304) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:921) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:135) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:646) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:546) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:460) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:131) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
06:51:10.240 [nioEventLoopGroup-3-4] WARN c.c.client.dcp.conductor.Conductor - Cannot connect configuration provider.
06:51:10.240 [nioEventLoopGroup-3-4] DEBUG c.c.client.dcp.conductor.Conductor - Instructed to shutdown.
06:51:10.244 [nioEventLoopGroup-3-4] DEBUG c.c.c.d.c.HttpStreamingConfigProvider - Initiating streaming config provider shutdown on channel.
06:51:10.244 [nioEventLoopGroup-3-4] INFO c.c.client.dcp.conductor.Conductor - Shutdown complete.
06:51:10.333 [task-thread-couchbase-kafka-connector-baymax-stage-0] INFO o.a.k.c.runtime.WorkerSourceTask - WorkerSourceTask{id=couchbase-kafka-connector-baymax-stage-0} Committing offsets
06:51:10.334 [task-thread-couchbase-kafka-connector-baymax-stage-0] INFO o.a.k.c.runtime.WorkerSourceTask - WorkerSourceTask{id=couchbase-kafka-connector-baymax-stage-0} flushing 0 outstanding messages for offset commit
06:51:10.334 [task-thread-couchbase-kafka-connector-baymax-stage-0] DEBUG o.a.k.c.runtime.WorkerSourceTask - WorkerSourceTask{id=couchbase-kafka-connector-baymax-stage-0} Finished offset commitOffsets successfully in 1 ms
06:51:10.335 [task-thread-couchbase-kafka-connector-baymax-stage-0] ERROR o.a.kafka.connect.runtime.WorkerTask - WorkerSourceTask{id=couchbase-kafka-connector-baymax-stage-0} Task threw an uncaught and unrecoverable exception
org.apache.kafka.connect.errors.ConnectException: com.couchbase.client.dcp.error.BootstrapException: Could not connect to Cluster/Bucket
at com.couchbase.connect.kafka.CouchbaseSourceTask.poll(CouchbaseSourceTask.java:194) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:289) ~[connect-runtime-6.0.1-ccs.jar:na]
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:256) ~[connect-runtime-6.0.1-ccs.jar:na]
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185) ~[connect-runtime-6.0.1-ccs.jar:na]
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235) ~[connect-runtime-6.0.1-ccs.jar:na]
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[na:na]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[na:na]
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[na:na]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
Caused by: com.couchbase.client.dcp.error.BootstrapException: Could not connect to Cluster/Bucket
at com.couchbase.client.dcp.Client$6.call(Client.java:346) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.Client$6.call(Client.java:343) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at rx.Completable$26$1.onError(Completable.java:1742) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at rx.internal.operators.CompletableOnSubscribeConcatArray$ConcatInnerSubscriber.onError(CompletableOnSubscribeConcatArray.java:63) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at rx.Completable$19$1.onError(Completable.java:1393) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at rx.internal.operators.CompletableOnSubscribeTimeout$2.onError(CompletableOnSubscribeTimeout.java:99) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at rx.Completable$26$1$1.onError(Completable.java:1765) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.conductor.HttpStreamingConfigProvider$3$1.operationComplete(HttpStreamingConfigProvider.java:193) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.conductor.HttpStreamingConfigProvider$3$1.operationComplete(HttpStreamingConfigProvider.java:176) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:512) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:505) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:484) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:425) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:113) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:84) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:39) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:312) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:286) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:335) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1304) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:356) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:342) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:921) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:135) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:646) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeysPlain(NioEventLoop.java:546) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:460) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:131) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
at com.couchbase.client.deps.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
… 1 common frames omitted
Caused by: com.couchbase.client.core.CouchbaseException: Unknown error code during connect: 400 Bad Request
at com.couchbase.client.dcp.transport.netty.StartStreamHandler.channelRead0(StartStreamHandler.java:81) ~[kafka-connect-couchbase-3.4.6-SNAPSHOT.jar:na]
… 24 common frames omitted