如何通过 Kafka connect 在 Elastic Search 中创建多个索引

How to make more than one index in Elastic Search from Kafka connect

我正在从 AWS Aurora --> MSK --> Elastic search 流式传输数据。 我想在弹性搜索中创建索引的记录中有 3 列。 那么这可以在 Kafka connect 中完成吗? 那么当 kafka connect 从 Mysql 获取记录时,它可以放入弹性搜索并在三列上创建索引吗?

您可以显式地使用 jdbc 源的 query 配置到 select 这三列

您需要单独的连接器 运行 创建单独的 elasticsearch 索引,或者尝试使用主题索引映射配置 属性