从Kafka流式传输到Elasticsearch时的主题映射



当我传输或流式传输两个和三个表时,我可以在Elasticsearch中轻松映射,但我可以自动映射主题以索引吗

我已经通过手动映射topic.index.map=topic1:index1,topic2:index2等将数据从PostgreSQL流式传输到ES。

我可以自动映射生产者发送的任何主题,然后消费者在ES连接器中自动消费吗?

默认情况下,主题直接映射到同名索引。

如果您想要"更好"的控制,可以在transforms属性中使用RegexRouter

引用文件

topic.index.map

现在不赞成使用此选项。未来的版本可能会将其完全删除。请使用单个消息转换,如RegexRouter,将主题名称映射到索引名称

如果您不能为连接器中的每个主题捕获一个正则表达式,则使用不同的模式运行更多连接器

相关内容

  • 没有找到相关文章

最新更新