我正在学习mongodb kafka连接器教程:https://docs.mongodb.com/kafka-connector/current/kafka-docker-example
当mongo集合有更新时 pagewiews
希望看到一个mongosourceconnector将消息馈送到 test.pageviews
主题。我没有看到创建的主题,也没有看到生成的消息。
我正在严格按照教程进行。我所做的唯一调整是将schema注册表的端口更改为8017。启动应用程序(包括mongo复制数据库)时,终端输出似乎正常
在Kafka连接控制中心(在localhost:9021),我可以看到连接器“mongo source”存在,但它没有关联的主题。
在Kafka连接控制中心的主题中,没有 test.pageviews
主题已生成。
我尝试在kafka connect control center中手动创建主题,然后运行curl调用来创建连接器:
{"name": "mongo-source",
"config": {
"tasks.max":"2",
"connector.class":"com.mongodb.kafka.connect.MongoSourceConnector",
"connection.uri":"mongodb://mongo1:27017,mongo2:27017,mongo3:27017",
"database":"test",
"collection":"pageviews"
}}' http://localhost:8083/connectors -w "\n"
当手动创建主题时,我确实在kafka connect中看到了它,但是我在其中没有看到任何消息,即使在手动更新db之后(从mongo命令行w/ db.collection.findOneAnd Update()
)
有什么想法吗?似乎我一定错过了一些简单的东西,因为这是“你好世界”的应用程序!
暂无答案!
目前还没有任何答案,快来回答吧!