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:
us...@infra.apache.org


Reply via email to