Kafka主题返回0条消息

Question

我有一个使用Confluent平台将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

怎么调试到底是怎么回事？连接密码，主题都设置正确，我不知道从哪里开始调试。

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

​

Answer 1

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

对于我的mongo连接，新的URI语法修复了这个问题(你没有指向数据库的问题，这是在单独的选项卡中完成的)

​

​