qafro1 commented on issue #1209:
URL:
https://github.com/apache/camel-kafka-connector/issues/1209#issuecomment-877200556
KafkaConnector name: pubsub issue after sending datastreams:
```
name: pubsub
tasks:
- id: 0
state: FAILED
trace: "org.apache.kafka.connect.errors.ConnectException: Exiting
WorkerSinkTask due to unrecoverable exception.\n\tat
org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:609)\n\tat
org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:329)\n\tat
org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:232)\n\tat
org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:201)\n\tat
org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:182)\n\tat
org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:231)\n\tat
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat
java.bas
e/java.lang.Thread.run(Thread.java:829)\nCaused by:
org.apache.kafka.connect.errors.ConnectException: Exchange delivery has
failed!\n\tat
org.apache.camel.kafkaconnector.CamelSinkTask.put(CamelSinkTask.java:199)\n\tat
org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:581)\n\t...
10 more\nCaused by: org.apache.camel.ResolveEndpointFailedException: Failed to
resolve endpoint: google-pubsub
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
