mongodb - Kafka 主题返回 0 条消息

Question

我有一个实时流程，使用 Confluent Platform 将 MongoDB 中发生的事件直接流式传输到 Snowflake。Confluent 在我的本地计算机上作为 docker 映像建立，我没有发现任何问题：

     Name                    Command                  State                         Ports
------------------------------------------------------------------------------------------------------------
broker            /etc/confluent/docker/run        Up             0.0.0.0:9092->9092/tcp
connect           /etc/confluent/docker/run        Up (healthy)   0.0.0.0:8083->8083/tcp, 9092/tcp
control-center    /etc/confluent/docker/run        Up             0.0.0.0:9021->9021/tcp
ksql-datagen      bash -c echo Waiting for K ...   Up
ksqldb-cli        /bin/sh                          Up
ksqldb-server     /etc/confluent/docker/run        Up (healthy)   0.0.0.0:8088->8088/tcp
rest-proxy        /etc/confluent/docker/run        Up             0.0.0.0:8082->8082/tcp
schema-registry   /etc/confluent/docker/run        Up             0.0.0.0:8081->8081/tcp
zookeeper         /etc/confluent/docker/run        Up             0.0.0.0:2181->2181/tcp, 2888/tcp, 3888/tcp

过去几天一切正常，今天我用 powershell 重新运行了我的过程：

docker-compose exec broker bash和kafka-console-consumer --topic <MY_TOPIC> --bootstrap-server broker:9092

我注意到，当我将数据插入到 Mongo 的集合中时，Kafka 主题看不到它，而是返回Processed a total of 0 messages

如何调试发生了什么？连接密码，主题都设置正确，我不知道从哪里开始调试。

我曾经得到以下结果，但现在它是空闲的：

标签： mongodbapache-kafkaconfluent-platformkafka-topic

Answer 1

好的，在 Confluent Control CenterConnect选项卡中检查源连接器的设置。

对于我的 mongo 连接，新的 URI 语法解决了这个问题（你不指向数据库的那个，在单独的选项卡中完成）