kafka-connect-elasticsearch
kafka-connect-elasticsearch copied to clipboard
Kafka Connect Elasticsearch connector
## Problem Scripted Upserts are not currently possible inside of the Update Request sent to ElasticSearch Also, the Kafka Payload is always sent in as either doc or upsert. ##...
## Problem ``` $ git checkout 11.1.x $ git merge 11.0.x CONFLICT (modify/delete): Jenkinsfile deleted in 11.0.x and modified in HEAD. Version HEAD of Jenkinsfile left in tree. CONFLICT (modify/delete):...
…properties ## Problem ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [ ] no ##### If yes, where? ## Test Strategy ##### Testing done:...
…properties ## Problem ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [ ] no ##### If yes, where? ## Test Strategy ##### Testing done:...
Add scripted upsert functionality to ES Sink Connector ## Problem Need scripted upsert functionality to support older Elastic Search client/server version Also, need ability to inject Kafka payload as Params...
## Problem ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [ ] no ##### If yes, where? ## Test Strategy ##### Testing done: -...
## Problem The current max retry back off time is set at a constant of 24 hours. This duration is too long to be practical. ## Solution Making the duration...
## Problem Original PR - https://github.com/confluentinc/kafka-connect-elasticsearch/pull/742 PR to expose this config on cloud - https://github.com/confluentinc/kafka-connect-elasticsearch-private/pull/43 ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [...
## Problem There is no support for ApiKey Header authentication which is used in ES cloud version ## Solution Add a new property to put the API Key and use...