Kafka 主题 returns 0 条消息

Question

我有一个 real-time 进程，它使用 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

过去几天一切正常，今天我 re-ran 我使用 powershell 的过程：

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

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

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

我曾经得到以下结果，但现在它闲置了：

Answer 1

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

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

Kafka 主题 returns 0 条消息

Kafka topic returns 0 messages

mongodb

apache-kafka

kafka-topic

confluent-platform