小编Abh*_*ece的帖子

如何更改Kafka Connect Source Connector生成的主题名称

我有一个已经在运行的生产部署了 Kafka-Cluster 并且有主题“现有主题”。我正在使用 Debezium 的 MongoDB-Source-Connector。

在这里,我想要的只是将 CDC 事件直接推送到主题“现有主题”,以便我的已经在收听该主题的消费者能够处理它。

我没有找到任何资源可以这样做,但是有人提到该主题是以以下格式创建的 -

“如果你的mongodb.name参数是A,数据库名称是B,集合名称是C,那么数据库A和集合C的数据将被加载到主题ABC下”

我可以将主题更改为“现有主题”并将事件推送给它吗?

apache-kafka apache-kafka-connect mongodb-kafka-connector

5
推荐指数
1
解决办法
1780
查看次数