apache / camel-kafka-connector-examples

Apache Camel Kafka Connector Examples
https://camel.apache.org
64 stars 43 forks source link

Add CamelGooglesheetsSinkConnector example #328

Open bhanusoni opened 2 years ago

bhanusoni commented 2 years ago

I am using the google sheet sink connector of camel-Kafka-connector version 0.11.x. I am deploying a camel-Kafka-connector in Kubernetes. I am using the following configuration in the Kubernetes kind Kafka connector. I am following the https://camel.apache.org/camel-kafka-connector/0.11.x/reference/connectors/camel-google-sheets-kafka-sink-connector.html page to set up but facing an error. Please add an example of how to use the google sheet sink in Kafka connector. Below is an error that was also posted. Any help would be appreciated.

kind: KafkaConnector apiVersion: kafka.strimzi.io/v1beta2 metadata: name: google-sheet-sink labels:

must match connect cluster name

strimzi.io/cluster: my-connect

spec: tasksMax: 1 class: org.apache.camel.kafkaconnector.googlesheets.CamelGooglesheetsSinkConnector config: topics: my-topic camel.sink.path.apiName: data camel.sink.path.methodName: append camel.sink.endpoint.applicationName: kafka-connect camel.sink.endpoint.clientId: camel.sink.endpoint.clientSecret: camel.sink.endpoint.accessToken: camel.sink.endpoint.refreshToken: camel.sink.endpoint.spreadsheetId: ***** camel.component.google-sheets-stream.range: A1:B2

Error: ERROR Failed delivery for (MessageId: E91EB7DEADAF674-0000000000000000 on ExchangeId: E91EB7DEADAF674-0000000000000000). Exhausted after delivery attempt: 1 caught: org.apache.camel.RuntimeCamelException: Missing properties for append, need one or more from [values, range]

Message History (complete message history is disabled)

RouteId ProcessorId Processor Elapsed (ms) [route10 ] [route10 ] [ ] [ 5] ... [route10 ] [toD10 ] [google-sheets:data/append?accessToken=xxxxxx ] [ 0]

Stacktrace

(org.apache.camel.processor.errorhandler.DefaultErrorHandler) [task-thread-google-sheet-sink-0] org.apache.camel.RuntimeCamelException: Missing properties for append, need one or more from [values, range]