काफ्का विषय 0 संदेश देता है

मेरे पास एक रीयल-टाइम प्रक्रिया है जो मोंगोडीबी में होने वाली घटनाओं को सीधे कंफ्लुएंट प्लेटफॉर्म का उपयोग करके स्नोफ्लेक पर स्ट्रीम करती है। मेरी स्थानीय मशीन पर डोकर छवि के रूप में कंफ्लुएंट स्थापित किया गया है और मुझे कोई समस्या नहीं दिख रही है:

     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

पिछले दिनों सब कुछ काम कर रहा था और आज मैंने अपनी प्रक्रिया को शक्तियों के साथ फिर से चलाया:

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

मैंने देखा है कि जब मैं मोंगो के संग्रह में डेटा सम्मिलित करता हूं तो काफ्का विषय इसे नहीं देखता है, इसके बजाय Processed a total of 0 messages देता है

क्या हो रहा है डीबग कैसे करें? कनेक्शन पासवर्ड, विषय सभी सही ढंग से सेट हैं और मुझे नहीं पता कि डिबगिंग कहां से शुरू करें।

मुझे परिणाम नीचे मिलता था लेकिन अब यह निष्क्रिय है: