不带表名的kafka connect topic.prefix

7lrncoxx 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(413)

我使用的是jdbc源连接器，我的表名有特殊字符（即$），db引擎可以接受，但是当我使用下面的配置运行kafka connect时，它试图用这个前缀创建kafka主题，加上表名，但是表名上的特殊字符不一定能被kafka接受。是否可以使用静态目标主题名而不是依赖源表名？

"topic.prefix":"blah-"

apache-kafka apache-kafka-connect

来源：https://stackoverflow.com/questions/58014643/kafka-connect-topic-prefix-without-the-table-name

1条答案

按热度按时间

ndh0cuux1#

我最终使用了Kafka连接转换，如下面所示，使其工作。仍然不确定是否会有任何性能拖累，因为smt，但它目前的工作

"transforms":"dropSomething",
            "transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
            "transforms.dropPrefix.regex":"(.*)\\$",
            "transforms.dropPrefix.replacement":"$1"

赞(0）回复(0）举报 2021-06-04

我来回答

不带表名的kafka connect topic.prefix

1条答案

相关问题

热门标签

最新问答