Skip to content
This repository has been archived by the owner on Jun 1, 2022. It is now read-only.

Latest commit

 

History

History
37 lines (24 loc) · 1.38 KB

README.md

File metadata and controls

37 lines (24 loc) · 1.38 KB
Raw

Kafka Connect OpenSearch Connector

DEPRECATED: This repoitory is deprecated. Please use the aiven one instead.

kafka-connect-opensearch is a fork of Confluent's kafka-connect-elasticsearch.
It allows runnig a Kafka Connector for copying data between Kafka and OpenSearch.

Usage

Installation

Each release publishes a JAR of the package which can be downloaded and used directly.

KAFKA_CONNECT_OPENSEARCH_VERSION=0.0.2
curl -L -o /tmp/kafka-connect-opensearch.jar https://github.com/dmathieu/kafka-connect-opensearch/releases/download/${KAFKA_CONNECT_OPENSEARCH_VERSION}/kafka-connect-opensearch.jar

Once you have the JAR file, move it to a path recognised by Java, such as /usr/share/java/.

Configuration

Once the JAR is installed, you can configure a connector using it. Create your connector using the com.dmathieu.kafka.opensearch.OpenSearchSinkConnector class.

{
  [...]
  "connector.class": "com.dmathieu.kafka.opensearch.OpenSearchSinkConnector",
  [...]
}

About the license

Everything coming from the Confluent fork is licensed under the Confluent Community License.
Everything that has changed from the Elasticsearch version is licensed under the MIT license.