我已经部署了Kafka-Cluster,并且已经在运行该产品,并且主题为“ existing-topic”。我正在使用Debezium的MongoDB-Source-Connector。
这里,我只想将CDC事件直接推送到主题“ existing-topic”,以便已经在听该主题的我的消费者将对其进行处理。
我没有找到这样做的任何资源,但是提到该主题是以以下格式创建的-
“如果您的mongodb.name参数为A,数据库名称为B,集合名称为C,则来自数据库A和集合C的数据将被加载到主题A.B.C下”
我可以将主题更改为“ existing-topic”并将事件推送到该主题吗?
Kafka主题的名称总是采用以下形式
logicalName.databaseName.collectionName
,其中logicalName
是logical name指定的连接器的mongodb.name
配置属性,databaseName
是数据库的名称,其中操作发生,collectionName
是MongoDB的名称受影响的文档所在的集合。
这意味着,如果连接器的逻辑名称为myConnector
,并且数据库myDatabase
具有两个集合users
和orders
,那么Kafka Connect将使用名称填充两个主题:
myConnector.myDatabase.users
myConnector.myDatabase.orders