No description, website, or topics provided.
Java Shell
Switch branches/tags
Nothing to show
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.

Kafka Connect Elasticsearch

kafka-connect-elasticsearch is a Kafka Connector for loading data from Kafka into Elasticsearch.
More explanation can be found in the article Kafka and Elastic Search, A Perfect Match.



Build a package of the code:

mvn clean package

Open a console and export env variable:


Start docker containers:

docker-compose up

Open another console window and export DOCKER_IP env variable

Run connector:


Go to http://{YOUR_DOCKER_IP_ADDRESS}:9200/kafka_recipes/_search to check your imported recipes