Kako proizvajate in potrošite sporočila v Kafki (osnovna uporaba)?

Question

Accepted Answer

Osnovna uporaba Kafke vključuje **proizvajanje** sporočil v temo in njihovo **porabo** — običajno prek knjižnice odjemalca (Java, Python, itd.). Razumevanje osnovnega toka proizvajanja/porabe je praktični vstopni punkt za uporabo Kafke.

## Proizvajanje sporočil

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

## Poraba sporočil

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

## Ključne praktične točke

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

## Zakaj je to pomembno

Razumevanje osnovne uporabe proizvajanja/porabe je dragoceno, ker je to **praktični vstopni punkt za uporabo Kafke**, zato je potrebno praktično znanje za delo s Kafko.

Znanje, kako proizvajati in potrošiti sporočila, je temeljni spretnost za uporabo Kafke v aplikacijah.

Razumevanje **proizvajanja sporočil** — povezovanje proizvajalca in pošiljanje zapisov (ključ, vrednost) v temo, kjer **ključ določa razdeljevanje in vrstni red** — je osnovna operacija pisanja.

Razumevanje **porabe sporočil** — povezovanje potrošnika z **ID skupino**, naročilo na temo in obdelava sporočil (z offseti, ki se samodejno ali ročno potrdijo) — je osnovna operacija branja, pri čemer je skupina potrošnikov način, kako se poraba skalira.

Razumevanje **ključnih praktičnih točk** — uporaba knjižnice odjemalca za svoj jezik (Java, KafkaJS, Python, itd.), nastavitev ključev za vrstni red in konfiguriranje acks za trajnost na proizvajalcih, uporaba ID skupin in potrditev offsetov na potrošnikih, obravnava **serializacije** (JSON, Avro, Protobuf, pogosto s registrom shem za strukturirane podatke) in obravnava napak, ponovnih poskusov ter **idempotentne obdelave** (ker zagotovljena najmanjša enkratna dostava pomeni mogoče podvojenih sporočil) — odraža praktične premisleke za resnično uporabo Kafke.

Te praktične točke (ključi, skupine, serializacija, idempotentnost) povezujejo konceptualno znanje (particije, skupine potrošnikov, semantika dostave) z dejanskim kodom.

Ker je proizvajanje in poraba sporočil temeljna praktična spretnost za uporabo Kafke v aplikacijah, in ker je razumevanje osnovnega toka in praktičnih točk (ključi, skupine, serializacija, idempotentnost) potrebno praktično znanje, je razumevanje osnovne uporabe proizvodnje/porabe v Kafki dragoceno, praktično relevantno znanje — praktični vstopni punkt za uporabo Kafke, povezovanje konceptov s kodom in nujno za vsakogar, ki dejansko gradi aplikacije s Kafko.