kafka-connect-elasticsearch
kafka-connect-elasticsearch copied to clipboard
confluentinc
Kafka Connect Elasticsearch connector
## Problem The current version of the connector does not support ES 8 and above. ## Solution The High level rest client 7.17 has a compatibility mode which adds some...
## Problem This cherry-picks change from https://github.com/confluentinc/kafka-connect-elasticsearch/pull/648 ## Solution ##### Does this solution apply anywhere else? - [ ] yes - [ ] no ##### If yes, where? ## Test...
## Problem The connector currently (version 11.1.3) doesn't support writing to Elasticsearch alias. Aliases are a convenient way to make the management of the underlying indices easy - like mapping...
While running with elastic 8.0 cluster, _bulk API calls fail with following error. Caused by: java.lang.NullPointerException at java.base/java.util.Objects.requireNonNull(Objects.java:221) at org.elasticsearch.action.DocWriteResponse.(DocWriteResponse.java:127) Lets know what's the plan 1. Existing connector compatible with...
This looks like a repeat of https://github.com/confluentinc/kafka-connect-elasticsearch/issues/582 https://packages.confluent.io/maven/io/confluent/kafka-connect-elasticsearch/ only contains version up to 11.1.4 but confluent hub is showing 11.1.7 With the latest log4shell vulnerability this lag has become more...
I tried to configure kafka-connect-elasticsearch 11.1.2 with my cluster which is built with OpenSearch binaries and got an error: ```Connector configuration is invalid and contains the following 1 error(s): Connector...
Borrowed most code from https://github.com/confluentinc/kafka-connect-elasticsearch/pull/330/ as it is old and conflict with current code. ## Problem Connecting to Amazon Managed service with IAM role authentication addressing feature request: https://github.com/confluentinc/kafka-connect-elasticsearch/issues/514 ##...
## Problem * Not able to custom version type * Not able to set custom version when use external version type ## Solution * add version.type configuration: internal, external, external_gte...
I have been encountering a weird issue with Kafka and Confluent Sink Connector which I am using in my setup. I have a system where in I have two kafka...
## Problem There is currently no way to sink messages with composite keys without ignoring those keys. Error "STRUCT is not supported as the document id." https://github.com/confluentinc/kafka-connect-elasticsearch/issues/193 ## Solution Convert...
