seravat commented on issue #1192:
URL:
https://github.com/apache/camel-kafka-connector/issues/1192#issuecomment-854530580
Sure! By the way, we are using the Strimzi/AMQ streams operator
```
spec:
class: >-
org.apache.camel.kafkaconnector.elasticsearchrest.CamelElasticsearchrestSinkConnector
config:
key.ignore: false
topics: sftr-payload
camel.sink.endpoint.hostAddresses: 'sftr-es-es-http:9200'
transforms: 'createKey,extractString'
camel.sink.endpoint.indexName: sftr-payload
camel.component.elasticsearch-rest.enableSSL: false
errors.tolerance: all
camel.component.elasticsearch-rest.user: elastic
errors.log.enable: true
key.converter: org.apache.kafka.connect.storage.StringConverter
camel.sink.endpoint.operation: Index
camel.sink.endpoint.enableSSL: false
errors.deadletterqueue.topic.name: dlq-sftr-payload
errors.deadletterqueue.context.headers.enable: true
errors.deadletterqueue.topic.replication.factor: 1
camel.component.elasticsearch-rest.password: 1z9Z36u0K1emWIKBR514oj3T
camel.sink.path.clusterName: sftr-es
tasksMax: 2
```
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
