汇合mongo kafka docker教程:kafka源连接器不生成到topic test.pageviews的消息

vulvrdjw  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(247)

我正在学习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() )
有什么想法吗?似乎我一定错过了一些简单的东西,因为这是“你好世界”的应用程序!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题