Panjenengan napa cara ngasilaken lan ngonsumsi pesen ing Kafka (panggunaan dasar)?

Question

Accepted Answer

Panggunaan Kafka dasar nyakup **ngasilaken** pesen menyang sawijining topik lan **ngonsumsi** mau — biasane liwat pustaka klien (Java, Python, lan sapanunggale). Pangerten babagan alur dasar produce/consume minangka titik mlebu praktis kanggo nggunakake Kafka.

## Ngasilaken pesen

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

## Ngonsumsi pesen

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

## Poin praktis kunci

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

## Gatekna apa

Nangerteni panggunaan produce/consume dasar iku makna amarga minangka **titik mlebu praktis kanggo nggunakake Kafka**, dadi kabutuhan pengetahuan hands-on kanggo nggarap Kafka.

Nangerteni cara ngasilaken lan ngonsumsi pesen minangka katrampilan pundasar kanggo nggunakake Kafka ing aplikasi.

Nangerteni **ngasilaken pesen** — nyambung producer lan ngirim rekaman (key, value) menyang topik, karo **key nentokake partisioning lan urutan** — minangka operasi nulis dasar.

Nangerteni **ngonsumsi pesen** — nyambung consumer karo **group ID**, mlayang menyang topik, lan ngolah pesen (karo offset committed kanthi manual utawa otomatis) — minangka operasi baca dasar, karo grup consumer minangka cara konsumsi berkembang.

Nangerteni **poin praktis kunci** — nggunakake pustaka klien kanggo basa sampeyan (Java, KafkaJS, Python, lan sapanunggale), nyetel key kanggo urutan lan konfigurasi acks kanggo durabilitas ing producer, nggunakake group ID lan ngikat offset ing consumer, manangani **serialization** (JSON, Avro, Protobuf, asring karo schema registry kanggo data terstruktur), lan manangani kesalahan, retry, lan **idempotent processing** (amarga pengiriman minimal siji ngandhani kemungkinan duplikat) — cerminan pertimbangan praktis kanggo panggunaan Kafka nyata.

Poin praktis mau (key, group, serialization, idempotency) nyambung pengetahuan konsepsional (partisi, grup consumer, semantik pengiriman) menyang kode nyata.

Bab ngasilaken lan ngonsumsi pesen minangka katrampilan praktis pundasar kanggo nggunakake Kafka ing aplikasi, lan amarga pangerten babagan alur dasar lan poin praktis (key, group, serialization, idempotency) kabutuhan pengetahuan hands-on, pangerten panggunaan produce/consume Kafka dasar minangka makna, pengetahuan praktis-relevan — titik mlebu praktis kanggo nggunakake Kafka, nyambung konsep menyang kode, lan kabutuhan kanggo sapa wae sing nyata nggawe aplikasi karo Kafka.