Kafka मा संदेशहरू कसरी उत्पादन र उपभोग गर्ने हो (आधारभूत प्रयोग)?

Question

Accepted Answer

आधारभूत Kafka प्रयोगमा **संदेशहरू उत्पादन** गरेर विषयमा पठाउने र तिनलाई **उपभोग गर्ने** समावेश छ — सामान्यतः क्लायन्ट लाइब्रेरी (Java, Python, आदि) मार्फत। आधारभूत produce/consume प्रवाह बुझ्नु Kafka प्रयोगको व्यावहारिक प्रवेश बिन्दु हो।

## संदेशहरू उत्पादन गर्ने

```js
// using a Kafka client (e.g. KafkaJS for Node)
const producer = kafka.producer();
await producer.connect();
await producer.send({
  topic: 'orders',
  messages: [
    { key: 'user-123', value: JSON.stringify({ orderId: 1, amount: 100 }) },
    // key determines the partition (same key → same partition → ordering)
  ],
});
// → publishes the message to the 'orders' topic
```

## संदेशहरू उपभोग गर्ने

```js
const consumer = kafka.consumer({ groupId: 'order-processors' });   // a consumer GROUP
await consumer.connect();
await consumer.subscribe({ topic: 'orders', fromBeginning: false });
await consumer.run({
  eachMessage: async ({ topic, partition, message }) => {
    const data = JSON.parse(message.value.toString());
    // process the message...
    // offset is auto-committed (or commit manually for control)
  },
});
```

## मुख्य व्यावहारिक बिन्दुहरू

```text
✓ Use a client LIBRARY for your language (Java, KafkaJS, confluent-kafka-python, etc.)
✓ Producers: set a KEY for ordering/partitioning; configure acks for durability
✓ Consumers: use a GROUP ID; the group distributes partitions; commit offsets
✓ Handle SERIALIZATION (JSON, Avro, Protobuf) — often a schema registry for structured data
✓ Handle errors, retries; process idempotently (at-least-once → possible duplicates)
```

## यो किन महत्त्वपूर्ण छ

आधारभूत produce/consume प्रयोग बुझ्नु मूल्यवान छ किनकि यो **Kafka प्रयोगको व्यावहारिक प्रवेश बिन्दु** हो, त्यसैले Kafka सँग काम गर्नको लागि यो आवश्यक हात-पेमालको ज्ञान हो।

संदेशहरू उत्पादन र उपभोग गर्न जानु Kafka प्रयोगको लागि मौलिक कौशल हो।

**संदेशहरू उत्पादन गर्ने** बुझ्नु — producer जोडेर र विषयमा रेकर्डहरू (key, value) पठाउने, **key को विभाजन र क्रमनिरुपण निर्धारण गरेर** — आधारभूत लेखन क्रिया हो।

**संदेशहरू उपभोग गर्ने** बुझ्नु — **group ID** सँग consumer जोडेर विषयमा सदस्यता लेर संदेशहरू (offsets स्वचलित वा म्यानुएली committed) प्रक्रिया गर्ने — आधारभूत पढन क्रिया हो, consumer group उपभोग कसरी मापनयोग्य हुन्छ भन्ने तरीका हो।

**मुख्य व्यावहारिक बिन्दुहरू** बुझ्नु — आफ्नो भाषाको लागि client library प्रयोग गर्ने (Java, KafkaJS, Python, आदि), क्रमनिरुपणको लागि keys प्रयोग गर्ने र producers मा acks कन्फिगर गर्ने स्थायित्वको लागि, consumers मा group IDs र offsets committing प्रयोग गर्ने, **serialization** ह्यान्डल गर्ने (JSON, Avro, Protobuf, अक्सर structured data को लागि schema registry सँग), र त्रुटि, पुनः प्रयास, र **idempotent processing** ह्यान्डल गर्ने (किनकि at-least-once delivery को अर्थ सम्भावित duplicates छ) — वास्तविक Kafka प्रयोगको लागि व्यावहारिक विचारहरू प्रतिबिम्बित गर्दछ।

यी व्यावहारिक बिन्दुहरू (keys, groups, serialization, idempotency) संकल्पनात्मक ज्ञान (partitions, consumer groups, delivery semantics) लाई वास्तविक कोडसँग जोडदछ।

संदेशहरू उत्पादन र उपभोग गर्नु Kafka मा अनुप्रयोग प्रयोगको मौलिक व्यावहारिक कौशल भएको र आधारभूत प्रवाह र व्यावहारिक बिन्दुहरू (keys, groups, serialization, idempotency) बुझ्नु आवश्यक हात-पेमालको ज्ञान भएको कारणले, आधारभूत Kafka produce/consume प्रयोग बुझ्नु मूल्यवान, व्यावहारिक रूपमा प्रासंगिक ज्ञान हो — Kafka को व्यावहारिक प्रवेश बिन्दु, अवधारणाहरूलाई कोडसँग जोडेर, र वास्तवमा Kafka सँग अनुप्रयोगहरू निर्माण गरिरहेको कोहीपनको लागि आवश्यक।