Kafka-connect-zeebe ping pong example error

Hello!
I followed the instructions in ping-pong example. I am using the docker-compose-local-kafka.yml and Camunda Platform SaaS.
When I start the ping connector, the connect-1 container throws the following error:

docker-connect-1          | [2022-08-08 15:43:07,426] TRACE Nothing to publish, returning control to caller after backoff (io.zeebe.kafka.connect.source.ZeebeSourceTask)
docker-control-center-1   | [2022-08-08 15:43:08,296] WARN misconfigured topic=_confluent-command config=segment.bytes value=1073741824 expected=134217728 (io.confluent.controlcenter.healthcheck.HealthCheck)
docker-control-center-1   | [2022-08-08 15:43:08,296] WARN misconfigured topic=_confluent-command config=delete.retention.ms value=86400000 expected=259200000 (io.confluent.controlcenter.healthcheck.HealthCheck)
docker-control-center-1   | [2022-08-08 15:43:12,374] INFO 172.20.0.1 - - [08/Aug/2022:15:43:12 +0000] "GET /api/connect/connect-default/connectors?expand=status&expand=info HTTP/1.1" 200 544  5 (io.confluent.rest-utils.requests)
docker-schema-registry-1  | [2022-08-08 15:43:17,144] INFO 172.20.0.7 - - [08/Aug/2022:15:43:17 +0000] "HEAD / HTTP/1.1" 200 0  2 (io.confluent.rest-utils.requests)
docker-control-center-1   | [2022-08-08 15:43:17,380] INFO 172.20.0.1 - - [08/Aug/2022:15:43:17 +0000] "GET /api/connect/connect-default/connectors?expand=status&expand=info HTTP/1.1" 200 544  6 (io.confluent.rest-utils.requests)
docker-connect-1          | [2022-08-08 15:43:17,426] TRACE Sending activate jobs command for maximal 100 jobs of type ping with request timeout PT10S (io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher)
docker-connect-1          | [2022-08-08 15:43:17,476] WARN Expected to fetch maximal 100 jobs for type ping, but failed to do so (io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher)
docker-connect-1          | java.util.concurrent.ExecutionException: io.grpc.StatusRuntimeException: UNIMPLEMENTED: HTTP status code 404
docker-connect-1          | invalid content-type: text/plain; charset=utf-8
docker-connect-1          | headers: Metadata(:status=404,server=nginx/1.17.7,date=Mon, 08 Aug 2022 15:43:17 GMT,content-type=text/plain; charset=utf-8,strict-transport-security=max-age=15724800; includeSubDomains,content-length=21)
docker-connect-1          | DATA-----------------------------
docker-connect-1          | default backend - 404
docker-connect-1          | DATA-----------------------------
docker-connect-1          |
docker-connect-1          |     at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
docker-connect-1          |     at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
docker-connect-1          |     at io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher.activateJobs(ZeebeSourceTaskFetcher.java:85)
docker-connect-1          |     at io.zeebe.kafka.connect.source.ZeebeSourceTaskFetcher.fetchBatch(ZeebeSourceTaskFetcher.java:54)
docker-connect-1          |     at io.zeebe.kafka.connect.source.ZeebeSourceTask.lambda$fetchJobs$0(ZeebeSourceTask.java:94)
docker-connect-1          |     at io.zeebe.kafka.connect.util.ManagedClient.withClient(ManagedClient.java:53)
docker-connect-1          |     at io.zeebe.kafka.connect.source.ZeebeSourceTask.fetchJobs(ZeebeSourceTask.java:94)
docker-connect-1          |     at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:269)
docker-connect-1          |     at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
docker-connect-1          |     at java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
docker-connect-1          |     at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
docker-connect-1          |     at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
docker-connect-1          |     at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
docker-connect-1          |     at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
docker-connect-1          |     at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
docker-connect-1          |     at io.zeebe.kafka.connect.source.ZeebeSourceTask.poll(ZeebeSourceTask.java:76)
docker-connect-1          |     at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:276)
docker-connect-1          |     at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:243)
docker-connect-1          |     at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)
docker-connect-1          |     at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)
docker-connect-1          |     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
docker-connect-1          |     at java.util.concurrent.FutureTask.run(FutureTask.java:266)
docker-connect-1          |     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
docker-connect-1          |     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
docker-connect-1          |     at java.lang.Thread.run(Thread.java:748)
docker-connect-1          | Caused by: io.grpc.StatusRuntimeException: UNIMPLEMENTED: HTTP status code 404
docker-connect-1          | invalid content-type: text/plain; charset=utf-8
docker-connect-1          | headers: Metadata(:status=404,server=nginx/1.17.7,date=Mon, 08 Aug 2022 15:43:17 GMT,content-type=text/plain; charset=utf-8,strict-transport-security=max-age=15724800; includeSubDomains,content-length=21)
docker-connect-1          | DATA-----------------------------
docker-connect-1          | default backend - 404
docker-connect-1          | DATA-----------------------------
docker-connect-1          |
docker-connect-1          |     at io.grpc.Status.asRuntimeException(Status.java:535)
docker-connect-1          |     at io.grpc.stub.ClientCalls$StreamObserverToCallListenerAdapter.onClose(ClientCalls.java:478)
docker-connect-1          |     at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:562)
docker-connect-1          |     at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:70)
docker-connect-1          |     at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:743)
docker-connect-1          |     at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:722)
docker-connect-1          |     at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37)
docker-connect-1          |     at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133)
docker-connect-1          |     ... 3 more
docker-connect-1          | [2022-08-08 15:43:17,477] TRACE Nothing to publish, returning control to caller after backoff (io.zeebe.kafka.connect.source.ZeebeSourceTask)

If anyone can help I would appreciate it.
Thanks!

Hi @mPatrik

It looks like it throws when it sends an ActivateJobs API call to the Camunda SaaS gateway, with a status 404.

This can happen when the client in unauthenticated. Are the credentials correct and configured correctly?

Josh

Hello!
Yea, the region code was incorrect…

Thank you!

1 Like