MCPcopy Index your code
hub / github.com/confluentinc/kafka-connect-elasticsearch

github.com/confluentinc/kafka-connect-elasticsearch @v15.1.2

Chat with this repo
repository ↗ · DeepWiki ↗ · release v15.1.2 ↗ · + Follow
701 symbols 2,903 edges 43 files 116 documented · 17%
What it actually does AI analysis from the code graph — generated when you open this
loading…
README

Kafka Connect Elasticsearch Connector

FOSSA Status

Changelog for this connector can be found here.

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

Development

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.

Configuring

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" ]
}'

Contribute

  • Source Code: https://github.com/confluentinc/kafka-connect-elasticsearch
  • Issue Tracker: https://github.com/confluentinc/kafka-connect-elasticsearch/issues
  • Learn how to work with the connector's source code by reading our Development and Contribution guidelines.

License

This project is licensed under the Confluent Community License.

FOSSA Status

Extension points exported contracts — how you extend this code

ExternalResourceExistenceStrategy (Interface)
Interface for external resource existence checking strategies. [4 implementers]
src/main/java/io/confluent/connect/elasticsearch/ExternalResourceExistenceChecker.java
OffsetTracker (Interface)
Tracks processed records to calculate safe offsets to commit. [3 implementers]
src/main/java/io/confluent/connect/elasticsearch/OffsetTracker.java
OffsetState (Interface)
(no doc) [4 implementers]
src/main/java/io/confluent/connect/elasticsearch/OffsetState.java

Core symbols most depended-on inside this repo

put
called by 623
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkTask.java
validate
called by 68
src/main/java/io/confluent/connect/elasticsearch/Validator.java
addErrorMessage
called by 58
src/main/java/io/confluent/connect/elasticsearch/Validator.java
createIndexOrDataStream
called by 42
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java
close
called by 31
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java
updateOffsets
called by 31
src/main/java/io/confluent/connect/elasticsearch/OffsetTracker.java
flush
called by 30
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java
preProcessSchema
called by 30
src/main/java/io/confluent/connect/elasticsearch/DataConverter.java

Shape

Method 639
Class 52
Enum 6
Interface 4

Languages

Java100%

Modules by API surface

src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkConnectorConfig.java84 symbols
src/test/java/io/confluent/connect/elasticsearch/ValidatorTest.java59 symbols
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchClient.java37 symbols
src/test/java/io/confluent/connect/elasticsearch/ElasticsearchSinkConnectorConfigTest.java36 symbols
src/test/java/io/confluent/connect/elasticsearch/ElasticsearchSinkTaskTest.java35 symbols
src/test/java/io/confluent/connect/elasticsearch/ElasticsearchClientTest.java35 symbols
src/test/java/io/confluent/connect/elasticsearch/helper/ElasticsearchContainer.java33 symbols
src/test/java/io/confluent/connect/elasticsearch/integration/ElasticsearchConnectorIT.java32 symbols
src/test/java/io/confluent/connect/elasticsearch/DataConverterTest.java31 symbols
src/main/java/io/confluent/connect/elasticsearch/Validator.java23 symbols
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkTask.java21 symbols
src/test/java/io/confluent/connect/elasticsearch/integration/ElasticsearchConnectorBaseIT.java19 symbols

For agents

$ claude mcp add kafka-connect-elasticsearch \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact

Ask about this repo answers extend the page