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

     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 देता है

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

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

1
marcin2x4 28 नवम्बर 2020, 23:48

1 उत्तर

सबसे बढ़िया उत्तर

ठीक है, कंफ्लुएंट कंट्रोल सेंटर Connect टैब में सोर्स कनेक्टर के लिए सेटिंग चेक करें।

मेरे मोंगो के कनेक्शन के लिए, नए यूआरआई सिंटैक्स ने इस मुद्दे को ठीक किया (जहां आप डेटाबेस को इंगित नहीं करते हैं, जो अलग टैब में किया जाता है)

enter image description here

1
OneCricketeer 30 नवम्बर 2020, 03:11