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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to