qafro1 edited a comment on issue #1209:
URL:
https://github.com/apache/camel-kafka-connector/issues/1209#issuecomment-871558258
I've tested this locally.
$bin/connect-standalone.sh config/connect-standalone.properties
/opt/kafka/connectors/docs/examples/CamelGooglepubsubSinkConnector.properties
but get an error msg:
```
Caused by: io.grpc.StatusRuntimeException: INVALID_ARGUMENT: One or more
messages in the publish request is empty. Each message must contain either
non-empty data, or at least one attribute.
at io.grpc.Status.asRuntimeException(Status.java:533)
... 13 more
[2021-06-30 17:16:10,722] INFO Stopping CamelSinkTask connector task
(org.apache.camel.kafkaconnector.CamelSinkTask:210)
[2021-06-30 17:16:10,723] INFO Apache Camel 3.11.0-SNAPSHOT (camel-1)
shutting down (timeout:45s)
(org.apache.camel.impl.engine.AbstractCamelContext:3190)
[2021-06-30 17:16:10,729] INFO Routes shutdown summary (total:1 stopped:1)
(org.apache.camel.impl.engine.AbstractCamelContext:3389)
[2021-06-30 17:16:10,729] INFO Stopped route1 (direct://start)
(org.apache.camel.impl.engine.AbstractCamelContext:3394)
[2021-06-30 17:16:10,748] INFO Apache Camel 3.11.0-SNAPSHOT (camel-1)
shutdown in 24ms (uptime:3s559ms)
(org.apache.camel.impl.engine.AbstractCamelContext:3330)
[2021-06-30 17:16:10,748] INFO CamelSinkTask connector task stopped
(org.apache.camel.kafkaconnector.CamelSinkTask:224)
[2021-06-30 17:16:10,748] INFO [Consumer
clientId=connector-consumer-CamelGoogle-pubsubSinkConnector-0,
groupId=connect-CamelGoogle-pubsubSinkConnector] Revoke previously assigned
partitions test-topic-0
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:307)
```
--
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]
