Need help with kafka-connect-elasticsearch?
Click the “chat” button below for chat support from the developer who created it, or find similar developers for support.

About the developer

627 Stars 351 Forks Other 1.8K Commits 79 Opened issues


Kafka Connect Elasticsearch connector

Services available


Need anything else?

Contributors list

Kafka Connect Elasticsearch Connector

FOSSA Status

kafka-connect-elasticsearch is a Kafka Connector for copying data between Kafka and Elasticsearch.


To build a development version you'll need a recent version of Kafka as well as a set of upstream Confluent projects, which you'll have to build from their appropriate snapshot branch. See the FAQ for guidance on this process.

You can build kafka-connect-elasticsearch with Maven using the standard lifecycle phases.


Creating an Elasticsearch user and assigning required privileges

Create an Elasticsearch role

curl -u elastic:elastic -X POST "localhost:9200/_security/role/es_sink_connector_role?pretty" -H 'Content-Type: application/json' -d'
  "indices": [
      "names": [ "*" ],
      "privileges": ["create_index", "read", "write", "view_index_metadata"]

Create an Elasticsearch user

curl -u elastic:elastic -X POST "localhost:9200/_security/user/es_sink_connector_user?pretty" -H 'Content-Type: application/json' -d'
  "password" : "seCret-secUre-PaSsW0rD",
  "roles" : [ "es_sink_connector_role" ]


  • Source Code:
  • Issue Tracker:


This project is licensed under the Confluent Community License.

FOSSA Status

We use cookies. If you continue to browse the site, you agree to the use of cookies. For more information on our use of cookies please see our Privacy Policy.