卡夫卡的主题转换

Question

我的数据如下，

{"empid"="100","empname="test"}

现在，我的转变是，

'transforms' ='IndexName',
'transforms.IndexName.type' = 'io.confluent.connect.transforms.ExtractTopic$Value',
'transforms.IndexName.field' = 'test',
'transforms.IndexName.skip.missing.or.null' = 'true'

我正在创建用于弹性搜索的水槽连接器。在使用上述变换的同时，我可以创建索引名称；测试"；。但我想自定义索引名称，如"；test100"；。有可能吗？

Answer 1

您需要使用多个转换来将test修改为testblah

在提取后添加RegexRouter，以使用静态内容更新主题名称

"transforms" = "IndexName,AddSuffix"
"transforms.IndexName.type" = ...
...
"transforms.AddSuffix.type" = ...
...

如果您试图提取empid=100字段，则没有当前变换可以提取&连接多个字段，我会质疑您的设计选择，因为每个empid都有一个Elasticsearch索引