从kafka流到elasticsearch时的主题Map

eufgjt7s  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(254)

当我传输或流式传输两个和三个表时,我可以很容易地在elasticsearch中Map,但是我可以自动Map主题到索引吗
我已经通过手动Map将数据从postgresql流式传输到es topic.index.map=topic1:index1,topic2:index2 等等。
我可以自动Map生产者发送的主题,然后消费者在es连接器中自动消费吗?

sg3maiej

sg3maiej1#

默认情况下,主题直接Map到同名索引。
如果你想要更好的控制,你可以使用 RegexRouter 在一个 transforms 财产
引用文档 topic.index.map 现在不推荐使用此选项。将来的版本可能会完全删除它。请使用单个消息转换,例如 RegexRouter ,将主题名称Map到索引名称
如果不能为连接器中的每个主题捕获一个正则表达式,则使用不同的模式运行更多连接器

相关问题