【发布时间】:2020-04-25 16:48:03
【问题描述】:
我正在从 AWS Aurora --> MSK --> Elastic search 流式传输数据。 我想在弹性搜索中创建索引的记录中有 3 列。 那么这可以在 Kafka connect 中完成吗? 那么当kafka connect从Mysql获取记录时,它可以放入弹性搜索并在三列上创建索引吗?
【问题讨论】:
标签: elasticsearch apache-kafka apache-kafka-connect
我正在从 AWS Aurora --> MSK --> Elastic search 流式传输数据。 我想在弹性搜索中创建索引的记录中有 3 列。 那么这可以在 Kafka connect 中完成吗? 那么当kafka connect从Mysql获取记录时,它可以放入弹性搜索并在三列上创建索引吗?
【问题讨论】:
标签: elasticsearch apache-kafka apache-kafka-connect
您可以显式使用 jdbc 源的query 配置来选择这三列
您需要运行单独的连接器来创建单独的弹性搜索索引,或者尝试使用主题索引映射配置属性
【讨论】: