Klien Apache Kafka untuk Mac

Masukkan host dan port satu broker; anggota cluster lainnya ditemukan melaluinya, dan Additional Bootstrap Servers mencantumkan broker yang dicoba jika broker pertama tidak menjawab. Satu koneksi adalah satu cluster, sehingga tidak ada bidang Database, dan bilah samping langsung menampilkan topiknya.

Security Protocol adalah PLAINTEXT, SSL, SASL_PLAINTEXT, atau SASL_SSL, dan SASL Mechanism adalah PLAIN, SCRAM-SHA-256, atau SCRAM-SHA-512. PLAIN cocok untuk Confluent Cloud; SCRAM untuk Amazon MSK dan broker yang dihosting sendiri. Dengan SSL atau SASL_SSL tanpa mode SSL yang dipilih, rantai sertifikat dan nama host diverifikasi. CA pribadi dimasukkan ke CA Certificate, dan sertifikat serta kunci klien menambahkan TLS timbal balik.

Melalui tunnel SSH, koneksi tetap pada broker bootstrap, sehingga hanya membaca partisi yang dipimpin broker tersebut. Import from URL… menerima URL kafka://, yang tidak dibuka macOS sebagai tautan.

Membuka topik menampilkan pesan terbaru, dengan pesan paling baru di akhir, beserta partisi, offset, timestamp, kunci, nilai, header, dan ukuran. Pesan dari partisi berbeda diselingi berdasarkan timestamp untuk membantu pembacaan; partisi dan offset mengidentifikasi pesan. Kunci atau nilai yang bukan UTF-8 ditampilkan sebagai heksadesimal, dan tombstone tetap dibedakan dari pesan kosong.

KafkaQL mengganti pengurutan dan filter dengan posisi awal: CONSUME "orders" FROM NEWEST, FROM OLDEST, FROM OFFSET, atau FROM TIME dengan timestamp ISO 8601, secara opsional dibatasi pada beberapa partisi. SHOW TOPICS, SHOW BROKERS, SHOW GROUPS, SHOW CLUSTER, dan DESCRIBE TOPIC mencakup bagian cluster lainnya.

DESCRIBE GROUP adalah laporan lag: offset yang di-commit, offset akhir, dan selisihnya per partisi. Partisi yang belum pernah di-commit grup tidak menampilkan lag, alih-alih angka yang dihitung dari nol, dan SHOW GROUPS menandai daftar terpotong jika broker tidak dapat diakses.

PRODUCE INTO menulis pesan dengan kunci, header, dan partisi opsional. Pesan berkunci tanpa partisi ditempatkan seperti yang dilakukan producer Kafka sendiri. Batch gzip, snappy, lz4, dan zstd didekompresi saat dibaca, tanpa pengaturan yang perlu dipilih.

Sel tidak dapat diedit, baris tidak dapat dihapus, dan kolom tidak dapat diurutkan karena Kafka tidak memiliki pembaruan, penghapusan per pesan, atau pengurutan di server, dan grid menonaktifkan kontrol tersebut. Setiap halaman melanjutkan dari akhir halaman sebelumnya, sehingga topik yang menerima tulisan baru tidak pernah mengulangi atau melewatkan pesan.

Menghapus topik dari bilah samping atau dengan DROP TOPIC adalah satu-satunya tindakan destruktif. Cluster menghapus log setelahnya, sehingga topik mungkin tetap muncul sebentar dalam daftar. Truncate tidak tersedia: Kafka menghapus record berdasarkan retensi atau offset per partisi, dan keduanya tidak mengosongkan topik.

Impor tidak tersedia; masukkan pesan ke topik menggunakan PRODUCE INTO. Ekspor pesan yang dibaca kueri sebagai CSV, JSON, atau XLSX.

Aplikasi iPhone dan iPad tidak memiliki driver Apache Kafka. Koneksi Apache Kafka yang disinkronkan dari Mac muncul dalam daftar tetapi tidak dapat dibuka.