kafka topic返回0条消息

ubby3x7f 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(390)

我有一个实时流程，使用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 如何调试正在发生的事情？连接密码，主题都设置正确，我不知道从哪里开始调试。
我以前得到的结果如下，但现在它是空闲的：