使用analyzer将kafka连接插入字段

d8tt03nd  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(260)

我有一个简单的弹性场。我还有一个Kafka主题,其中包含相同类型的avro记录(aka string/text)。首先我在所有字段的弹性上创建一个索引,包括这个分析器,
索引:

{
"aliases": {},
"mappings": {
"_default_": {"_all": {"enabled": true}},
"test": { "properties":{ "mUrl": {"type": "text", "analyzer": "simple"}}}
},
"order": 0,
"settings": {"index.mapping.coerce": true, "index.mapping.ignore_malformed": true, "index.number_of_replicas": 0, "index.refresh_interval": "5s"},
"template": "test-*"
}

avro文件是由kafka connect(使用schema registry)创建的。来自包含一个字段murl的sqlserver,该字段可为空nvarchar(500)
错误:
[test]的Map器与其他类型中的现有Map冲突:
[mapper[test]具有不同的[analyzer]]

暂无答案!

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

相关问题