Unknown host exception when local kafka connects to camunda cloud

Hello all, I’m currently trying out the zeebe-kafka connector:

My setup is local docker kafka + camunda cloud platform

After I successfully deploy the kafka connector (source.json) to http:// localhost: 8083/connectors, the error log keeps coming up:

connect_1 | [2022-09-26 04:11:24,715] TRACE Sending activate jobs command for maximal 100 jobs of type ping with request timeout PT1S (io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher)
connect_1 | [2022-09-26 04:11:24,715] WARN Expected to fetch maximal 100 jobs for type ping, but failed to do so (io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher)
connect_1 | java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNAVAILABLE: Unable to resolve host 758d8c83-08ae-4c56-ad28-c1bf5a45bed3.dsm-1.zeebe.camunda.io
connect_1 | at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
connect_1 | at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
connect_1 | at io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher.activateJobs(ZeebeSourceTaskFetcher.java:85)
connect_1 | at io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher.fetchBatch(ZeebeSourceTaskFetcher.java:54)
connect_1 | at io.zeebe.kafka.connect.source.ZeebeSourceTask.lambda$fetchJobs$0(ZeebeSourceTask.java:94)
connect_1 | at io.zeebe.kafka.connect.util.ManagedClient.withClient(ManagedClient.java:53)
connect_1 | at io.zeebe.kafka.connect.source.ZeebeSourceTask.fetchJobs(ZeebeSourceTask.java:94)
connect_1 | at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:269)
connect_1 | at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
connect_1 | at java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
connect_1 | at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
connect_1 | at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
connect_1 | at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
connect_1 | at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
connect_1 | at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
connect_1 | at io.zeebe.kafka.connect.source.ZeebeSourceTask.poll(ZeebeSourceTask.java:76)
connect_1 | at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:276)
connect_1 | at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:243)
connect_1 | at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)
connect_1 | at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)
connect_1 | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
connect_1 | at java.util.concurrent.FutureTask.run(FutureTask.java:266)
connect_1 | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
connect_1 | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
connect_1 | at java.lang.Thread.run(Thread.java:748)
connect_1 | Caused by: io.grpc.StatusRuntimeException: UNAVAILABLE: Unable to resolve host 758d8c83-08ae-4c56-ad28-c1bf5a45bed3. dsm-1. zeebe. camunda. io
connect_1 | at io.grpc.Status.asRuntimeException(Status.java:535)
connect_1 | at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:478)
connect_1 | at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:562)
connect_1 | at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:70)
connect_1 | at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:743)
connect_1 | at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:722)
connect_1 | at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
connect_1 | at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
connect_1 | … 3 more
connect_1 | Caused by: java.lang.RuntimeException: java.net.UnknownHostException: 758d8c83-08ae-4c56-ad28-c1bf5a45bed3. dsm-1. zeebe. camunda. io: Name or service not known
connect_1 | at io.grpc.internal.DnsNameResolver.resolveAddresses(DnsNameResolver.java:223)
connect_1 | at io.grpc.internal.DnsNameResolver.doResolve(DnsNameResolver.java:282)
connect_1 | at io.grpc.internal.DnsNameResolver$Resolve.run(DnsNameResolver.java:318)
connect_1 | … 3 more
connect_1 | Caused by: java.net.UnknownHostException:
758d8c83-08ae-4c56-ad28-c1bf5a45bed3. dsm-1. zeebe. camunda. io: Name or service not known
connect_1 | at java.net.Inet4AddressImpl.lookupAllHostAddr(Native Method)
connect_1 | at java.net.InetAddress$2.lookupAllHostAddr(InetAddress.java:929)
connect_1 | at java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1324)
connect_1 | at java.net.InetAddress.getAllByName0(InetAddress.java:1277)
connect_1 | at java.net.InetAddress.getAllByName(InetAddress.java:1193)
connect_1 | at java.net.InetAddress.getAllByName(InetAddress.java:1127)
connect_1 | at io.grpc.internal.DnsNameResolver$JdkAddressResolver.resolveAddress(DnsNameResolver.java:631)
connect_1 | at io.grpc.internal.DnsNameResolver.resolveAddresses(DnsNameResolver.java:219)
connect_1 | … 5 more
connect_1 | [2022-09-26 04:11:24,716] TRACE Nothing to publish, returning control to caller after backoff (io.zeebe.kafka.connect.source.ZeebeSourceTask)

I double checked my camunda cloud client information should be correct, and I can also access camunda cloud Console and Operate etc.

I’m not sure whether it is related to my local docker proxy setting (I checked it is ok though).

I’d like to know anyone encountered this before and is there a quick solution for this.

Thank you!