Kafka 连接器插入将字符串转换为 属性
Kafka connector insert transform string into property
我正在使用 Kafa connect solr and I'm trying to find a way to change the solr url based on the passed in topic, I've been looking at 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=
如何在 solr.url 属性 中使用 RemoveString 值？
transforms 实际上只改变 Kafka 记录本身，而不是外部属性，例如连接任务可能使用的客户端
具体来说，查看 source code，您会发现它使用主题名称映射到各个客户端，但都是相同的 url
我正在使用 Kafa connect solr and I'm trying to find a way to change the solr url based on the passed in topic, I've been looking at 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=
如何在 solr.url 属性 中使用 RemoveString 值？
transforms 实际上只改变 Kafka 记录本身，而不是外部属性，例如连接任务可能使用的客户端
具体来说，查看 source code，您会发现它使用主题名称映射到各个客户端，但都是相同的 url