Jak v Kafce produkujete a konzumujete zprávy (základní použití)?

Question

Accepted Answer

Základní používání Kafky zahrnuje **odesílání** zpráv do tématu a jejich **konzumaci** — typicky prostřednictvím klientské knihovny (Java, Python, atd.). Pochopení základního toku produkce/konzumace je praktickým vstupním bodem pro práci s Kafkou.

## Produkování zpráv

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

## Konzumování zpráv

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

## Klíčové praktické body

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

## Proč na to záleží

Pochopení základního použití produkce/konzumace je cenné, protože je to **praktickým vstupním bodem pro práci s Kafkou**, a je to tedy nezbytná praktická znalost pro práci s Kafkou.

Vědět, jak produkovat a konzumovat zprávy, je základní dovedností pro používání Kafky v aplikacích.

Pochopení **produkování zpráv** — připojení producenta a odeslání záznamů (klíč, hodnota) do tématu, kde **klíč určuje particionování a pořadí** — je základní operace zápisu.

Pochopení **konzumování zpráv** — připojení consumera s **ID skupiny**, přihlášení se k tématu a zpracování zpráv (s offsety potvrzovanými automaticky nebo ručně) — je základní operace čtení, kde je skupiny consumerů způsobem, jak se konzumace škáluje.

Pochopení **klíčových praktických bodů** — používání klientské knihovny pro váš jazyk (Java, KafkaJS, Python, atd.), nastavení klíčů pro pořadí a konfiguraci acks pro trvanlivost na producerech, použití ID skupin a potvrzování offsetů na consumerech, manipulace se **serializací** (JSON, Avro, Protobuf, často se schematem registry pro strukturovaná data) a manipulace s chybami, opakováním pokusů a **idempotentním zpracováním** (protože at-least-once delivery znamená možné duplikáty) — odráží praktické úvahy pro reálné používání Kafky.

Tyto praktické body (klíče, skupiny, serializace, idempotence) propojují konceptuální znalosti (partice, consumer groups, delivery semantika) se skutečným kódem.

Protože produkování a konzumování zpráv je základní praktickou dovedností pro používání Kafky v aplikacích a protože pochopení základního toku a praktických bodů (klíče, skupiny, serializace, idempotence) je nezbytná praktická znalost, je pochopení základního použití produkce/konzumace v Kafce cenné, prakticky relevantní znalosti — praktickým vstupním bodem pro práci s Kafkou, propojením konceptů s kódem a nezbytné pro všechny, kteří skutečně budují aplikace s Kafkou.