[GitHub] [camel-kafka-connector] oscerd edited a comment on issue #1209: Issue with camel-google-pubsub-kafka-connector sink configuration

[GitBox <gi...@apache.org>]

oscerd edited a comment on issue #1209:
URL: https://github.com/apache/camel-kafka-connector/issues/1209#issuecomment-883339397


   This configuration in a local kafka works fine
   
   For sink connector:
   
   ```
   name=CamelGoogle-pubsubSinkConnector
   connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSinkConnector
   tasks.max=1
   
   # use the kafka converters that better suit your needs, these are just defaults:
   key.converter=org.apache.kafka.connect.storage.StringConverter
   value.converter=org.apache.kafka.connect.storage.StringConverter
   
   # comma separated topics to get messages from
   topics=test-2
   
   # mandatory properties (for a complete properties list see the connector documentation):
   # The Service account key that can be used as credentials for the PubSub publisher/subscriber. It can be loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the resource from different systems.
   camel.sink.endpoint.serviceAccountKey=file:/home/oscerd/kafka/demo/serviceaccountkey.json
   # 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-pubsub
   # The Google Cloud PubSub Project Id
   camel.sink.path.projectId=test-pubsub-320411
   ```
   
   As you may see I'm pointing a file locally to my filesystem with an absolute path.
   
   Same story for a source connector
   
   ```
   name=CamelGoogle-pubsubSourceConnector
   connector.class=org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSourceConnector
   tasks.max=1
   
   # use the kafka converters that better suit your needs, these are just defaults:
   key.converter=org.apache.kafka.connect.storage.StringConverter
   value.converter= org.apache.kafka.connect.converters.ByteArrayConverter
   
   # comma separated topics to send messages into
   topics=test-1
   
   # mandatory properties (for a complete properties list see the connector documentation):
   
   camel.source.endpoint.serviceAccountKey=file:/home/oscerd/kafka/demo/serviceaccountkey.json
   # The Destination Name. For the consumer this will be the subscription name, while for the producer this will be the topic name.
   camel.source.path.destinationName=test-pubsub-sub
   # The Google Cloud PubSub Project Id
   camel.source.path.projectId=test-pubsub-320411
   ```


-- 
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: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org