我可以更改由Kafka-Connect推送的主题

问题描述 投票:0回答:1

我已经部署了Kafka-Cluster,并且已经在运行该产品,并且主题为“ existing-topic”。我正在使用Debezium的MongoDB-Source-Connector。

这里,我只想将CDC事件直接推送到主题“ existing-topic”,以便已经在听该主题的我的消费者将对其进行处理。

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

“如果您的mongodb.name参数为A,数据库名称为B,集合名称为C,则来自数据库A和集合C的数据将被加载到主题A.B.C下”

我可以将主题更改为“ existing-topic”并将事件推送到该主题吗?

apache-kafka apache-kafka-streams apache-kafka-connect mongodb-kafka-connector
1个回答
0
投票

根据documentation

Kafka主题的名称总是采用以下形式logicalName.databaseName.collectionName,其中logicalNamelogical name指定的连接器的mongodb.name配置属性,databaseName是数据库的名称,其中操作发生,collectionName是MongoDB的名称受影响的文档所在的集合。


这意味着,如果连接器的逻辑名称为myConnector,并且数据库myDatabase具有两个集合usersorders,那么Kafka Connect将使用名称填充两个主题:

  • myConnector.myDatabase.users
  • myConnector.myDatabase.orders
© www.soinside.com 2019 - 2024. All rights reserved.