kafka-connect-opensearch
kafka-connect-opensearch copied to clipboard
dmathieu
Kafka Connect plugin for sending events to OpenSearch
I'm trying to use the kafka-connect-opensearch with kafka-connect but it keeps giving me "Failed to find any class that implements Connector and which name matches com.dmathieu.kafka.opensearch.OpenSearchSinkConnector, available connectors are: ...."...
1. I have configured the SASL_PLAINTEXT. 2. Updated connect-distributed.properties file - ``` bootstrap.servers=10.30.1.101:9092 group.id=connect-cluster key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=org.apache.kafka.connect.json.JsonConverter key.converter.schemas.enable=true value.converter.schemas.enable=true offset.storage.topic=connect-offsets offset.storage.replication.factor=1 config.storage.topic=connect-configs config.storage.replication.factor=1 status.storage.topic=connect-status status.storage.replication.factor=1 offset.flush.interval.ms=10000 listeners=HTTP://:8083 plugin.path=/home/devuser/connectors sasl.mechanism=PLAIN security.protocol=SASL_PLAINTEXT sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule...
Hi, I've tried to make `kafka-connect-elasticsearch` work with opensearch, and happen to know this project. I wonder this connect is support the default opensearch's docker image which is enabled the...
All Data Stream tests are currently disabled. We need to fix them and reenable them.
Kerberos configuration isn't setup in tests. We need to bring it back and reenable the tests.
To smoothen the migration, all tests are currently ignoring invalid/self-signed certificates. We need to get the generated certificate and validate it within the tests.