Kafka टॉपिक्स

Apache Kafka परिचय

Mike Metzger

Data Engineering Consultant

टॉपिक क्या है?

टॉपिक्स इवेंट्स के लॉजिकल समूह हैं
- रिलेशनल डेटाबेस की टेबल जैसा
- इवेंट लॉग
- मैसेज अपरिवर्तनीय होते हैं
- किसी टॉपिक के मैसेज पढ़े या लिखे जा सकते हैं, बदले नहीं जा सकते
- उम्र के आधार पर मैसेज हटाए जा सकते हैं

Kafka टॉपिक का चित्रण.png

टॉपिक्स बनाना

टॉपिक्स बनाने के कई तरीके

हम bin/kafka-topics.sh स्क्रिप्ट उपयोग करेंगे

bin/kafka-topics.sh 
    --bootstrap-server <server> 
    --topic <topicname>
    --create

उदाहरण

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 \
--topic orders --create

Created topic orders

अन्य वेरिएशन्स

bin/kafka-topics.sh --create के वैकल्पिक आर्ग्युमेंट्स
- --replication-factor <x>
  - टॉपिक का replication factor सेट करें
- --partitions <x>
  - पार्टिशन की संख्या मैन्युअली दें

उदाहरण

$ bin\kafka-topics.sh --bootstrap-server localhost:9092 \
--topic orders --create --replication-factor 3 \
--partitions 3

Created topic orders

--describe

bin/kafka-topics.sh --bootstrap-server <server> --topic <topicname> --describe
- टॉपिक कॉन्फ़िगरेशन का विवरण प्राप्त करें

उदाहरण

$ bin/kafka-topics.sh --bootstrap-server localhost:9092 \
   --topic orders --describe

Topic: orders-new TopicId: <topicid> PartitionCount: 3 ReplicationFactor: 1    
  Configs:
    Topic: orders-new    Partition: 0    Leader: 0    Replicas: 0    Isr: 0
    Topic: orders-new    Partition: 1    Leader: 0    Replicas: 0    Isr: 0
    Topic: orders-new    Partition: 2    Leader: 0    Replicas: 0    Isr: 0

टॉपिक्स हटाना

bin/kafka-topics.sh --bootstrap-server <server> --topic <topicname> --delete
- Kafka सर्वर से एक टॉपिक हटाएँ
- टॉपिक हटाने पर उसके सभी मैसेज भी हट जाते हैं

उदाहरण

$ bin/kafka-topics.sh --bootstrap-server localhost:9092
  --topic orders --delete

अभ्यास करते हैं!

Apache Kafka परिचय