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