Kafka连接器插入转换字符串为属性

Question

我正在使用Kafa connect solr，我正试图找到一种方法来根据传入的主题更改solr url，我一直在看Kafka connect_transforms来尝试实现这一目标。我的连接属性文件看起来像这样-

topics.regex=foo.*.bar
solr.url=http://127.0.0.1:8910/solr/RemoveString$Value
transforms=RemoveString
transforms.RemoveString.type=org.apache.kafka.connect.transforms.RegexRouter
transforms.RemoveString.regex=(^foo.)(w*d+)(.*)
transforms.RemoveString.replacement=$2

如何使用RemoveString值在solr。url属性?

Answer 1

transforms实际上只改变Kafka记录本身，而不是外部属性，例如Connect任务可能使用的客户端

具体来说，查看源代码，您将看到它使用主题名称映射到各个客户端，但都在相同的url