simplifadmin edited a comment on issue #1209:
URL:
https://github.com/apache/camel-kafka-connector/issues/1209#issuecomment-860714234
Update kafka-pubsub
```
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnector
metadata:
name: pubsub-kafka
namespace: kafka
labels:
# must match connect cluster name
strimzi.io/cluster: my-connect
spec:
class:
org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSinkConnector
tasksMax: 5
config:
#The Google Cloud PubSub Project Id
camel.sink.path.projectId: test
topics: test-topic
#The Destination Name. For the consumer this will be the subscription
name, while for the producer this will be the topic name.
camel.sink.path.destinationName: test-topic
```
**Kafka-connect : output**
2021-06-14 13:47:59,095 INFO [Consumer
clientId=connector-consumer-pubsub-kafka-0, groupId=connect-pubsub-kafka]
Member connector-consumer-pubsub-kafka-0-921dcb28-9357-4ac4-a767-42898b659fdf
sending LeaveGroup request to coordinator
my-cluster-kafka-1.my-cluster-kafka-brokers.kafka.svc:9092 (id: 2147483646
rack: null) due to the consumer is being closed
(org.apache.kafka.clients.consumer.internals.AbstractCoordinator)
[task-thread-pubsub-kafka-0]
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
