【发布时间】：2023-03-13 18:53:01
【问题描述】：
我遇到了与以下 URL 中提到的问题类似的问题。 Logstash -> Elasticsearch - update denormalized data 我从kafka得到了事件
【问题讨论】：
标签： elasticsearch apache-kafka logstash kafka-consumer-api logstash-configuration
【发布时间】：2023-03-13 18:53:01
【问题描述】：
您如何获得活动？
编写基于更改字段更新弹性搜索数据的代理可能是最简单的。
如果您使用 Kafka 获取此数据，您可以简单地在 Kafka 消费者中编写此代码，您可以在其中根据已更改的字段从 elasticsearch 获取所有文档。更新 json 结果以使用新数据进行更新，然后在 Elasticsearch 中更新。
写这篇文章的努力可能并不多。 2-3小时应该足够了。
【讨论】：
-
非常感谢。我是从kafka得到的事件，你的意思是：我需要在kafka客户端调用elasticsearch来获取需要更新的文档？
-
是的。我觉得这样做会更容易。