opensearch-connector-for-apache-kafka

opensearch-connector-for-apache-kafka copied to clipboard

Options for SSL

22

Hello, we have ssl enabled for REST on the Opensearch side. So, need somehow specify ssl options on the connector side. In the elasticsearch connector there were options like: ```...

arnitolog

Out of ordering of requests to opensearch

1

Hi Team, We are seeing an out of order problem for the requests to opensearch when using `index.write.method=upsert`. However we don't see this issue when we set `index.write.method=insert`. Below is...

Ramkumar-byte

Bumps `kafkaVersion` from 2.8.1 to 3.7.0. Updates `org.apache.kafka:connect-api` from 2.8.1 to 3.7.0 Updates `org.apache.kafka:connect-json` from 2.8.1 to 3.7.0 Updates `org.apache.kafka:connect-runtime` from 2.8.1 to 3.7.0 Updates `org.apache.kafka:kafka_2.13` from 2.8.1 to 3.7.0...

dependabot[bot]

Hello, we have Opensearch connector configured to send data to OS. However the records that are failing the due to serialization error is simply getting dropped and lost instead of...

Naga-1216

Connector periodically issues warnings: "Commit of offsets timed out"

2

We are in the process of evaluating and establishing a CDC system streaming change events from our databases into an Opensearch deployment. The Opensearch connector eventually pushing aggregated topics into...

ngc4579

Please update README and document connector.class

3

Please make the README more elaborate. It has been hours trying to get it going and the README doesn't help. It is not clear how to install, and how to...

jacojoubert12

We are facing this below error , please let us know if any changes needed to address. Caused by: com.fasterxml.jackson.core.exc.StreamConstraintsException: String length (20050912) exceeds the maximum length (20000000)\n\tat com.fasterxml.jackson.core.StreamReadConstraints.validateStringLength(StreamReadConstraints.java:324)\n\tat com.fasterxml.jackson.core.util.ReadConstrainedTextBuffer.validateStringLength(ReadConstrainedTextBuffer.java:27)\n\tat...

vijaynallusamy

Adding AWS SigV4 authentication

5

This pull request implements the AWS SigV4 as described in #197

fabiojmendes

Not working with AWS MSK Connect

11

I am trying to create the connector in AWS MSK. I took the latest zip file and created a custom plugin. It gives me error "There is an issue with...

rsharma1980

**New Feature:** Adding new connector configuration index.name.override which allows for defining a static index name that documents will be written to. **Current Behavior:** Current logic for the index name is...

porto88