Hogyan termelhet és fogyaszthat üzeneteket a Kafkában (alapvető használat)?

Question

Accepted Answer

Az alapvető Kafka-használat magában foglalja az **üzenetek termelését** egy topicba és azok **fogyasztását** — jellemzően klientkönytár (Java, Python, stb.) segítségével. Az alapvető produce/consume flow megértése a Kafka praktikus belépési pontja.

## Üzenetek termelése

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

## Üzenetek fogyasztása

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

## Kulcsfontosságú gyakorlati pontok

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

## Miért fontos

Az alapvető produce/consume használat megértése értékes, mert ez a **Kafka gyakorlati belépési pontja**, így szükséges gyakorlati tudás a Kafkával való munkához.

Az üzenetek termelésének és fogyasztásának módja a Kafka-alkalmazások alapvető képessége.

Az **üzenetek termelésének** megértése — egy producer csatlakoztatása és rekordok (key, value) küldése egy topicba, ahol a **key a particionálást és az ordenálást határozza meg** — az alapvető írási művelet.

Az **üzenetek fogyasztásának** megértése — egy consumer csatlakoztatása egy **group ID**-val, egy topicra való feliratkozás és üzenetek feldolgozása (offsetek automatikus vagy manuális commitálásával) — az alapvető olvasási művelet, ahol a consumer group az, hogy a fogyasztás hogyan skálázódik.

Az **kulcsfontosságú gyakorlati pontok** megértése — egy klientkönytár használata az Ön nyelvéhez (Java, KafkaJS, Python, stb.), kulcsok beállítása az ordenáláshoz és az acks konfigurálása a producerek tartósságához, group ID-k használata és offsetek commitálása a consumereknél, a **serialization** kezelése (JSON, Avro, Protobuf, gyakran sémaregisztrációval strukturált adatokhoz), valamint hibakezelés, újrapróbálkozások és az **idempotens feldolgozás** (mivel az at-least-once delivery lehetséges duplikátumot jelent) — a Kafka valós használatának gyakorlati megfontolásait tükrözi.

Ezek a gyakorlati pontok (kulcsok, csoportok, serialization, idempotencia) összekapcsolják a fogalmi tudást (partíciók, consumer csoportok, szállítási szemantika) a tényleges kóddal.

Mivel az üzenetek termelése és fogyasztása a Kafka-alkalmazások alapvető gyakorlati képessége, és mivel az alapvető flow és a gyakorlati pontok (kulcsok, csoportok, serialization, idempotencia) megértése szükséges gyakorlati tudás, a Kafka alapvető produce/consume használatának megértése értékes, gyakorlati relevanciával bíró tudás — a Kafka gyakorlati belépési pontja, fogalmak és kód összekapcsolása, és szükséges mindenkinek, aki valóban alkalmazásokat épít a Kafkával.