我遇到了一个类似于下面的url中提到的问题。logstash->elasticsearch-更新我从kafka那里得到的非规范化数据
raogr8fs1#
你是如何获得活动的？最简单的方法是编写一个代理，根据更改字段更新elasticsearch数据。如果您使用kafka来获取这些数据，您只需在kafka consumer中编写这些数据，就可以根据已更改的字段从elasticsearch获取所有文档。更新json结果以使用新数据进行更新，然后在elasticsearch中更新该结果。写这篇文章的努力可能不多。2-3小时就足够了。
1条答案
按热度按时间raogr8fs1#
你是如何获得活动的？
最简单的方法是编写一个代理，根据更改字段更新elasticsearch数据。
如果您使用kafka来获取这些数据，您只需在kafka consumer中编写这些数据，就可以根据已更改的字段从elasticsearch获取所有文档。更新json结果以使用新数据进行更新，然后在elasticsearch中更新该结果。
写这篇文章的努力可能不多。2-3小时就足够了。