apache-kafka
कफका कंसोल उपकरण

परिचय

काफ्का-विषयों

यह उपकरण आपको विषयों को सूचीबद्ध करने, बनाने, बदलने और वर्णन करने देता है।

सूची विषय:

kafka-topics  --zookeeper localhost:2181 --list

एक विषय बनाएँ:

kafka-topics  --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

एक विभाजन और कोई प्रतिकृति के साथ एक विषय बनाता है।

एक विषय का वर्णन करें:

kafka-topics  --zookeeper localhost:2181 --describe --topic test

एक विषय को बदलें:

# change configuration
kafka-topics  --zookeeper localhost:2181 --alter --topic test --config max.message.bytes=128000
# add a partition
kafka-topics  --zookeeper localhost:2181 --alter --topic test --partitions 2

(खबरदार: काफ्का किसी विषय के विभाजन की संख्या को कम करने का समर्थन नहीं करता है) ( विन्यास गुणों की इस सूची को देखें)

काफ्का-सांत्वना-निर्माता

यह टूल आपको कमांड-लाइन से संदेश उत्पन्न करने देता है।

किसी विषय पर सरल स्ट्रिंग संदेश भेजें:

kafka-console-producer --broker-list localhost:9092 --topic test
here is a message
here is another message
^D

(प्रत्येक नई पंक्ति एक नया संदेश है, जिसे रोकने के लिए ctrl + D या ctrl + C टाइप करें)

कुंजी के साथ संदेश भेजें:

kafka-console-producer --broker-list localhost:9092 --topic test-topic \
        --property parse.key=true \
        --property key.separator=,
key 1, message 1
key 2, message 2
null, message 3
^D

फ़ाइल से संदेश भेजें:

kafka-console-producer --broker-list localhost:9092 --topic test_topic < file.log

काफ्का-सांत्वना उपभोक्ता

यह टूल आपको किसी विषय के संदेशों का उपभोग करने देता है।

पुराने उपभोक्ता कार्यान्वयन का उपयोग करने के लिए, --bootstrap-server को --zookeeper से --zookeeper ।

सरल संदेश प्रदर्शित करें:

kafka-console-consumer --bootstrap-server localhost:9092 --topic test 

पुराने संदेशों का उपभोग करें:

पुराने संदेशों को देखने के लिए, आप --from-beginning विकल्प का उपयोग कर सकते हैं।

मुख्य-मूल्य संदेश प्रदर्शित करें :

kafka-console-consumer  --bootstrap-server localhost:9092 --topic test-topic \
    --property print.key=true \
    --property key.separator=, 

काफ्का-सरल-उपभोक्ता खोल

यह उपभोक्ता एक निम्न-स्तरीय उपकरण है जो आपको विशिष्ट विभाजन, ऑफसेट और प्रतिकृतियों से संदेशों का उपभोग करने की अनुमति देता है।

उपयोगी पैरामीटर:

• parition : विशिष्ट विभाजन (सभी डिफ़ॉल्ट) से उपभोग करने के लिए
• offset : शुरुआत ऑफसेट। शुरुआत से संदेशों का उपभोग करने के लिए -2 का उपयोग करें, -1 अंत से उपभोग करने के लिए।
• max-messages : प्रिंट करने के लिए संदेशों की संख्या
• replica : प्रतिकृति, ब्रोकर-लीडर के लिए डिफ़ॉल्ट (-1)

उदाहरण के लिए:

kafka-simple-consumer-shell  \
    --broker-list localhost:9092 \
    --partition 1 \
    --offset 4 \
    --max-messages 3 \
    --topic test-topic

विषय परीक्षण-विषय से ऑफसेट 4 में 1 शुरुआत से 3 संदेश प्रदर्शित करता है।

काफ्का उपभोक्ता समूहों

यह उपकरण आपको उपभोक्ता समूहों को सूचीबद्ध करने, वर्णन करने या हटाने की अनुमति देता है। उपभोक्ता समूहों के बारे में अधिक जानकारी के लिए इस लेख पर एक नज़र डालें।

यदि आप अभी भी पुराने उपभोक्ता कार्यान्वयन का उपयोग करते हैं, तो --bootstrap-server को --zookeeper से --zookeeper ।

सूची उपभोक्ता समूह:

kafka-consumer-groups  --bootstrap-server localhost:9092 --list
octopus

उपभोक्ता-समूह का वर्णन करें:

kafka-consumer-groups  --bootstrap-server localhost:9092 --describe --group octopus
GROUP          TOPIC           PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG       OWNER
octopus        test-topic      0          15              15              0         octopus-1/127.0.0.1
octopus        test-topic      1          14              15              1         octopus-2_/127.0.0.1

टिप्पणी : उपरोक्त आउटपुट में,

• current-offset उपभोक्ता उदाहरण की अंतिम प्रतिबद्ध ऑफसेट है,
• log-end-offset विभाजन की उच्चतम ऑफसेट है (इसलिए, इस कॉलम को समेटें आपको विषय के लिए कुल संदेश देता है)
• lag वर्तमान उपभोक्ता ऑफसेट और उच्चतम ऑफसेट के बीच का अंतर है, इसलिए उपभोक्ता कितना पीछे है,
• owner client.id का ग्राहक होता है (यदि निर्दिष्ट नहीं है, तो एक डिफ़ॉल्ट प्रदर्शित होता है)।

एक उपभोक्ता-समूह हटाएँ:

विलोपन केवल तब उपलब्ध होता है जब समूह मेटाडेटा को ज़ूकीपर (पुराने उपभोक्ता आपी) में संग्रहीत किया जाता है। नए उपभोक्ता एपीआई के साथ, दलाल मेटाडेटा विलोपन सहित सब कुछ संभालता है: समूह को समाप्त होने पर स्वचालित रूप से हटा दिया जाता है जब समूह समाप्त हो जाता है।

kafka-consumer-groups --bootstrap-server localhost:9092 --delete --group octopus