spring-boot - 将springboot输出保存到elasticsearch引擎

Question

我有REST API，通过它我可以使用spring-boot向Kafka服务器发送消息并获取消息。现在，我想将这些消息保存到elasticsearch。有人可以怎么做？

Answer 1

实际上，在这种情况下，这是一项系统工作，就像设置数据库存储体系结构一样。
简单明了:
首先，您需要确定要使用哪个ES版本，因为ES 2.x至7.x之间存在一些重大更改。这些差异可能会影响您设计存储架构的方式。
假设您使用的是最新的7.x ES，则需要创建一个索引，以便将从kafka提取的数据存储到该索引中。结帐https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-create-index.html
稍后您创建了索引，您需要应用并学习有关ES高级客户端和低端客户端的一些基础知识。低级别的REST客户端使您可以通过HTTP与ES群集进行基本连接。而且高级的REST客户端API为您提供了足够的方式来执行操作，例如文档CRUD，搜索和数据聚合。您可以通过maven轻松找到依赖项，并在Spring Boot应用程序中使用它们。结帐https://www.elastic.co/guide/en/elasticsearch/client/java-rest/master/java-rest-high.html