Getting data from Kafka into Elasticsearch is easy with the Kafka Connect sink connector.
Check out this video tutorial on how to use the connector and a walk through some of the common requirements when using it including
- Updating and deleting documents in Elasticsearch
- Handling schemas and field mappings, including Timestamp fields
- Changing the name of the target index
- Error handling
🎥 Watch it here: https://rmoff.dev/kafka-elasticsearch-video
👾 You can also try it all out for yourself and follow along with the code using Docker at https://rmoff.dev/kafka-elasticsearch
Top comments (0)