Si prodhoni dhe konsumoni mesazhe në Kafka (përdorimi bazik)?

Question

Accepted Answer

Përdorimi bazik i Kafka-s përfshin **prodhimin** e mesazheve në një temë dhe **konsumin** e tyre — zakonisht përmes një biblioteke klienti (Java, Python, etj.). Kuptimi i rrjedhës bazike të prodhimit/konsumit është pika praktike e hyrjes në përdorimin e Kafka-s.

## Prodhimi i mesazheve

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

## Konsumimi i mesazheve

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

## Pikat praktike kryesore

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

## Përse është i rëndësishëm

Kuptimi i përdorimit bazik të prodhimit/konsumit është i vlefshëm sepse është **pika praktike e hyrjes në përdorimin e Kafka-s**, kështu që është njohuri e nevojshme praktike për të punuar me Kafka-n.

Dija se si të prodhosh dhe të konsumuash mesazhe është aftësia themelore për të përdorur Kafka-n në aplikacione.

Kuptimi i **prodhimit të mesazheve** — lidhja e një produceri dhe dërgimi i rekordeve (çelës, vlerë) në një temë, me **çelësin që përcakton ndarjen dhe renditjen** — është operacioni bazik i shkrimit.

Kuptimi i **konsumimit të mesazheve** — lidhja e një konsumeri me një **ID grupi**, abonimi në një temë, dhe përpunimi i mesazheve (me offsetet e përcaktuara automatikisht ose me dorë) — është operacioni bazik i leximit, me grupin e konsumit që është se si konsumimi përshkallëzohet.

Kuptimi i **pikave praktike kryesore** — përdorimi i një biblioteke klienti për gjuhën tuaj (Java, KafkaJS, Python, etj.), vendosja e çelësave për renditje dhe konfigurimi i ack për qëndrueshmëri në producera, përdorimi i ID-ve të grupeve dhe përcaktimi i offseteve në konsumera, trajtimi i **serijalizimit** (JSON, Avro, Protobuf, shpesh me një regjistër skeme për të dhënat e strukturuara), dhe trajtimi i gabimeve, riprovjeve, dhe **përpunimit idempotent** (pasi përditësja të paktën një herë do të thotë duplikate të mundshme) — pasqyron konsideratat praktike për përdorimin real të Kafka-s.

Këto pika praktike (çelësat, grupet, serijalizimi, idempotenca) lidhin njohurinë konceptuale (ndarjet, grupet e konsumit, semantika e dorëzimit) me kodin aktual.

Pasi prodhimi dhe konsumimi i mesazheve është aftësia themelore praktike për të përdorur Kafka-n në aplikacione, dhe pasi kuptimi i rrjedhës bazike dhe pikave praktike (çelësat, grupet, serijalizimi, idempotenca) është njohuri e nevojshme praktike, kuptimi i përdorimit bazik të prodhimit/konsumit të Kafka-s është njohuri e vlefshme dhe praktike — pika praktike e hyrjes në përdorimin e Kafka-s, lidhja e koncepteve me kodin, dhe e nevojshme për këdo që në të vërtetë ndërton aplikacione me Kafka-n.