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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
