我正在尝试将 monodb 连接到 kafka，因此每当将新文档插入 mongo 时，我都会将数据发送到 kafka 主题。所以我使用融合集线器安装了 mongodb 连接器，配置 MongoSourceConnector.properties 如下：
name=mongo-source
connector.class=com.mongodb.kafka.connect.MongoSourceConnector
tasks.max=1
# Connection and source configuration
connection.uri=mongodb://127.0.0.1:27017/
database=dev
collection=users
topic.prefix=newuser
poll.max.batch.size=1000
poll.await.time.ms=5000
# Change stream options
pipeline=[]
batch.size=0
change.stream.full.document=updateLookup
collation=
重新启动融合 kafka 并将一些新文档插入到 mongo 中，但我在 kafka 上什么也没看到，没有创建新主题，似乎没有任何效果！我在这里错过了什么吗？还有什么我应该配置/运行的吗？
谢谢 ：）