Apache Kafka

Klik kanan di pohon ▸ Tambah ▸ Permintaan Kafka.

Konfigurasi umum

Kolom	Peran
URL	Daftar broker, dipisahkan koma: hote1:9092,hote2:9092 — seluruh stringnya diselesaikan oleh Handlebars sebelum dipotong-potong
Pengenal klien	clientId yang diumumkan kepada para broker
Topik	Topiknya, apa pun modenya
Mode	produce, consume, atau browse

Autentikasi

Kolom	Nilai
Mekanisme SASL	none, plain, scram-sha-256, scram-sha-512
Pengguna SASL / Kata sandi SASL	Kata sandinya menerima nilai bertipe Rahasia
TLS	Dapat diaktifkan secara terpisah — broker ber-TLS tanpa SASL berfungsi dengan mekanisme none

Mode produce

Kunci, nilai, header rekaman, dan secara opsional partisi. Tanpa partisi eksplisit, pembagi partisi bawaan pustaka kliennya yang berlaku. Responsnya mengembalikan metadata rekaman yang ditulis: topik, partisi, offset.

Mode consume

Kolom	Peran
Grup	groupId milik konsumernya
Offset awal	earliest, latest, atau specific
Offset spesifik	Sebuah string — offset Kafka adalah bilangan bulat 64 bit
Partisi	Sebuah filter di sisi klien: penugasan partisinya tetap dilakukan oleh grupnya

Mode browse

Memeriksa sebuah partisi tanpa grup konsumer: Restorm mengambil sejumlah pesan yang dibatasi lalu memutuskan koneksinya. Partisinya wajib diisi dalam mode ini.

Inilah alat yang tepat untuk melihat isi sebuah topik tanpa membuat grup maupun menggeser offset.

Di dalam sebuah skenario

• Kafka produce — aksi tunggal, mengembalikan metadata rekamannya;
• Kafka consume — berlangganan melalui grup konsumer dan memancarkan satu peristiwa per pesan;
• Tutup koneksi Kafka — menghentikan konsumsinya.

Lihat Koneksi dan aliran.

Cuplikan kode

Lima sasaran: JavaScript (kafkajs, untuk produksi dan konsumsi) dan kcat (produksi, konsumsi, pemeriksaan tanpa grup).