qafro1 commented on issue #1209:
URL: 
https://github.com/apache/camel-kafka-connector/issues/1209#issuecomment-876390235


   ```
   kind: KafkaConnector
   apiVersion: kafka.strimzi.io/v1beta2
   metadata:
     name: pubsub
     namespace: kafka
     labels:
       # must match connect cluster name
       strimzi.io/cluster: my-connect-cluster
   spec:
     tasksMax: 5
     class: 
org.apache.camel.kafkaconnector.googlepubsub.CamelGooglepubsubSinkConnector
     
     # 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
     config:
       # comma separated topics to get messages from
       topics: test-topic
       value.converter.schemas.enable: false
       # 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.component.google-pubsub.serviceAccountKey: 
${directory:/opt/kafka/external-configuration/google:key.json}
       # 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: 
${directory:/opt/kafka/external-configuration/google:key.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-topic
   ```
   Issue with Kafkaconnector version 0.10.1  - Any idea?
    Caused by: org.apache.kafka.connect.errors.DataException: JsonConverter 
with schemas.enable requires "schema" and "payload" fields and may not contain 
additional fields. If you are trying to deserialize plain JSON data, set 
schemas.enable=false in your converter configuration.


-- 
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-unsubscr...@camel.apache.org

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


Reply via email to