Mac 用 Apache Kafka クライアント

一つのブローカーのホストとポートを入力すると、残りのクラスタを検出します。Additional Bootstrap Servers は最初が応答しない場合に試すブローカーを指定します。一つの接続は一つのクラスタで、Database フィールドはなく、サイドバーにトピックを直接表示します。

Security Protocol は PLAINTEXT、SSL、SASL_PLAINTEXT または SASL_SSL、SASL Mechanism は PLAIN、SCRAM-SHA-256 または SCRAM-SHA-512 です。PLAIN は Confluent Cloud、SCRAM は Amazon MSK と自己ホストのブローカー向けです。SSL または SASL_SSL で SSL モード未選択なら証明書チェーンとホスト名を検証します。プライベート CA は CA Certificate、クライアント証明書と鍵は相互 TLS に使います。

SSH トンネル では接続がブートストラップブローカーに留まり、そのブローカーがリーダーのパーティションだけを読みます。Import from URL… は kafka:// URL を受け付けますが、macOS はリンクとして開きません。

トピックを開くと最近のメッセージを新しいものが最後になる順序で表示し、パーティション、オフセット、タイムスタンプ、キー、値、ヘッダーとサイズを示します。読みやすくするため異なるパーティションを時刻で混在させますが、メッセージの識別はパーティションとオフセットです。UTF-8 ではないキーや値は十六進数で表示し、tombstone と空のメッセージを区別します。

KafkaQL は並べ替えや絞り込みの代わりに開始位置を指定します。CONSUME "orders" FROM NEWEST、FROM OLDEST、FROM OFFSET または ISO 8601 時刻付き FROM TIME で、任意のパーティションに限定できます。SHOW TOPICS、SHOW BROKERS、SHOW GROUPS、SHOW CLUSTER と DESCRIBE TOPIC でクラスタの他の情報を確認します。

DESCRIBE GROUP はパーティションごとのコミット済みオフセット、末尾オフセットと差分を示す遅延レポートです。グループが一度もコミットしていないパーティションはゼロから数えず遅延なしと表示します。ブローカーにアクセスできないと SHOW GROUPS は一覧が不完全と示します。

PRODUCE INTO は任意のキー、ヘッダーとパーティションを持つメッセージを書き込みます。キーがありパーティション未指定なら Kafka 自身の producer と同じ場所に送ります。gzip、snappy、lz4、zstd バッチは読み取り時に展開し、設定の選択は不要です。

Kafka に更新、メッセージ単位の削除、サーバー側の並べ替えがないため、セル編集、行削除やカラムソートはできず、操作を無効表示にします。各ページは前の終了位置から続けるため、書き込み中のトピックでもメッセージを重複・欠落させません。

サイドバーや DROP TOPIC からのトピック削除が唯一の破壊的操作です。クラスタが後からログを削除するため、一覧にしばらく残ることがあります。Kafka は保持ポリシーかパーティションごとのオフセットでレコードを削除し、どちらもトピックを空にしないため Truncate は提供しません。

インポートはありません。PRODUCE INTO でトピックにメッセージを書き込みます。クエリで読んだメッセージを CSV、JSON または XLSX で エクスポート できます。

iPhone と iPad アプリには Apache Kafka ドライバーがありません。Mac から同期した Apache Kafka 接続は一覧に表示しますが、開けません。