kafka connect elasticsearch如何定义索引Map

cbjzeqam  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(192)

我正在使用kafka connect elasticsearch和一个自定义转换器,它扩展了标准 JsonConverter .
我有250多个不同事件类型的主题,因此我很高兴Kafka连接自动为我在elasticsearch中创建索引。
但是,我想禁用所有分析仪除了 keyword -分析器(此处不需要全文搜索)。
我该怎么做?如何以及在何处操作索引Map?
在我的自定义转换器中,我为我的负载推断模式,将其转换为Kafka连接特定的模式,然后返回 new SchemaAndValue(connectSchema, connectValue) 对象。
我想,然后使用特定于连接的模式来生成 mappings ,是真的吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题