Kaip gaminate ir vartojate žinutes Kafka (pagrindinė naudojimas)?

Question

Accepted Answer

Pagrindinė Kafka naudojimas apima **žinučių gamybą** į temą ir jų **vartojimą** — paprastai naudojant kliento biblioteką (Java, Python ir kt.). Pagrindinės gamyba/vartojimo srauto supratimas yra praktinis įėjimo taškas į Kafka naudojimą.

## Žinučių gamyba

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

## Žinučių vartojimas

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

## Pagrindiniai praktiniai punktai

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

## Kodėl tai svarbu

Pagerindinės gamyba/vartojimo naudojimo supratimas yra vertingas, nes tai **praktinis įėjimo taškas į Kafka naudojimą**, todėl tai būtinas praktinis žinios darbui su Kafka.

Žinojimas, kaip gaminti ir vartoti žinutes, yra pagrindinį įgūdį naudojant Kafka programose.

Supratimas apie **žinučių gamybą** — gamintojo prijungimą ir įrašų (raktas, reikšmė) siuntimą į temą, kai **raktas nustato skaidymą ir tvarką** — yra pagrindinė rašymo operacija.

Supratimas apie **žinučių vartojimą** — vartotojo prijungimą su **grupės ID**, prenumeratą į temą ir žinučių apdorojimą (su automatiškai arba rankiniu būdu patvirtintais offset'ais) — yra pagrindinė skaitymo operacija, kai vartotojų grupė nustato, kaip vartojimas išplečiamas.

Supratimas apie **pagrindinius praktinius punktus** — kliento bibliotekos naudojimą jūsų kalbai (Java, KafkaJS, Python ir kt.), raktų nustatymą tvarkai ir acks konfigūravimą darytojų tvarumui, grupės ID naudojimą ir offset'ų patvirtinimą vartotojams, **serializacijos** tvarkyma (JSON, Avro, Protobuf, dažnai su schema registry struktūrizuotiems duomenims) ir klaidų, pakartojimų ir **idempotentinio apdorojimo** tvarkymą (nes bent vieno karto pristatymas reiškia galimus dublikatus) — atspindi praktinius svarstymus, reikalingus realiam Kafka naudojimui.

Šie praktiniai punktai (raktai, grupės, serializacija, idempotencija) sujungia konceptualinę žinią (skaidalus, vartotojų grupės, pristatymo semantiką) su faktine kodu.

Kadangi žinučių gamyba ir vartojimas yra pagrindinis praktinis Kafka naudojimo programose įgūdis, ir kadangi pagrindinio srauto supratimas ir praktinių punktų supratimas (raktai, grupės, serializacija, idempotencija) yra būtina praktinė žinios, pagrindinės Kafka gamyba/vartojimo naudojimo supratimas yra vertingas, praktiškai aktualus žinios — praktinis įėjimo taškas į Kafka naudojimą, koncepcijų jungimas prie kodo ir būtinas bet kuriam, kuris iš tikrųjų konstruoja programas su Kafka.