На самом деле это систематическое c задание, в этом случае это похоже на настройку архитектуры хранилища базы данных.
ПРОСТО И КОРОТКО:
Сначала вам нужно решить, какую версию ES вы хотите использовать. потому что между ES 2.x и 7.x произошли серьезные изменения. И эти различия могут повлиять на то, как вы разрабатываете схему вашего хранилища.
Предположим, вы используете последнюю версию 7.x ES, вам нужно будет создать индекс (ы), где вы хотите, чтобы данные, извлекаемые из kafka, были сохранены. Оформить заказ https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-create-index.html
Позже у вас будут созданы индексы, вам необходимо применить и изучить некоторые базовые c знания о клиенте ES высокого уровня отдыха и клиенте низкого уровня отдыха. Низкоуровневый клиент покоя обеспечивает вам базовое c соединение с кластером ES через HTTP. А высокоуровневые остальные клиентские API дают вам достаточно возможностей для таких операций, как документы CRUD, поиск, агрегация ваших данных. Вы можете легко найти зависимости через maven и использовать их в своем приложении Spring Boot. Оформить заказ https://www.elastic.co/guide/en/elasticsearch/client/java-rest/master/java-rest-high.html