Conas a dhéanann tú teachtaireachtaí a tháirgeadh agus a ithe i Kafka (úsáid bhunúsach)?

Question

Accepted Answer

Baineann úsáid bhunúsach Kafka le teachtaireachtaí a **tháirgeadh** chuig topaig agus iad a **ithe** — go hiondúil trí leabharlann chliaint (Java, Python, etc.). Tá an práinn bunúsach táirgeadh/ithe ina ionad iontrálaigh praiticiúil chun Kafka a úsáid.

## Teachtaireachtaí a tháirgeadh

```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
```

## Teachtaireachtaí a ithe

```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)
  },
});
```

## Pointí praiticiúla ábhartha

```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)
```

## Cén fáth a bhí sé tábhachtach

Tá eolas bunúsach ar úsáid táirgeadh/ithe tábhachtach mar gur **ionad iontrálaigh praiticiúil do Kafka a úsáid** a atá ann, agus dá bharr sin is riachtanach an eolas praiticiúil seo chun Kafka a úsáid.

Is an scil bhunúsach é a bheith ábalta teachtaireachtaí a tháirgeadh agus a ithe chun Kafka a úsáid in fheidhmchláir.

Tá **teachtaireachtaí a tháirgeadh** — ceangal a dhéanamh le táirgeoir agus taifead (eochair, luach) a sheoladh chuig topaig, agus an **eochair ag cinneadh roinnt agus ordú** — ina ghnáthobair scríobh.

Tá **teachtaireachtaí a ithe** — ceangal a dhéanamh le tomhaltóir le **grúpaitheoirí ID**, a bheith liostaithe ar thopaig, agus teachtaireachtaí a phróiseáil (le fritháireamh gealltais a ghealadh go huathoibríoch nó i láimh an duine) — ina ghnáthobair léamh, agus an grúpa tomhaltóirí ag cur síos ar conas a scéalann tomhaltas.

Tá **pointí praiticiúla ábhartha** — leabharlann chliaint a úsáid do do theanga (Java, KafkaJS, Python, etc.), eochracha a shocrú chun ordú agus acks a rianúchán ar thonnta do láidreacht an táirgeora, grúpaitheoirí ID agus fritháireamh gealltais ar thomhaltóirí, **socrúchán** a láimhseáil (JSON, Avro, Protobuf, go minic le clárlann scéim do shonraí struchtúrtha), agus earráidí, atriail, agus **próiseáil idempotent** (ó tharla go bhfuil seachadadh ar a laghad uair amháin ann agus bheadh an féidireacht ann go mbeadh dúbailt ann) — ag fianaise na bharúlacha praiticiúla do Kafka iarbhír.

Tá na pointí praiticiúla seo (eochracha, grúpaí, socrúchán, idempotency) ag ceangal an eolais choincheapúil (páirt, grúpaí tomhaltóirí, semantics seachadadh) do chód iarbhír.

Ó tharla gur an scil bhunúsach praiticiúil é táirgeadh agus ithe teachtaireachtaí chun Kafka a úsáid in fheidhmchláir, agus ó tharla go bhfuil an príomh-shreabh agus na pointí praiticiúla (eochracha, grúpaí, socrúchán, idempotency) riachtanach d'eolas praiticiúil, tá eolas ar úsáid bhunúsach táirgeadh/ithe Kafka tábhachtach, a bhaineann go práinneach — an príomh-ionad iontrálaigh chun Kafka a úsáid, conairí a cheangal chun cód, agus riachtanach do aon duine ag tógáil feidhmchláir go fírinneach le Kafka.