適用於 Mac 的 Apache Kafka 用戶端
用 KafkaQL 從所選起點讀取主題,查看每個消費者群組的延遲,並產生測試訊息。主題是記錄,所以格線僅讀取訊息,從不編輯。
適用於 Mac首次選擇 Apache Kafka 時下載驅動程式


概覽
- 查詢語言
- KafkaQL
- 驅動程式
- 首次使用時下載
- 連線方式
- 主機與連接埠, SSH 通道, SSL/TLS
- 預設連接埠
- 9092
- 最低版本
- 0.11,文件所述
- iPhone 與 iPad
- 無法開啟
連線
輸入一個代理的主機和連接埠,從它探索叢集其餘部分。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 自身生產者會選擇的位置。讀取時自動解壓縮 gzip、snappy、lz4、zstd 批次,無須選擇設定。
Kafka 無更新、逐訊息刪除或伺服器端排序,因此無法編輯儲存格、刪除列或依欄位排序,相應控制項顯示停用。每頁從上頁停止處繼續,因此持續寫入的主題也不重複或略過訊息。
主題
從側欄或 DROP TOPIC 刪除主題是唯一破壞性操作。叢集隨後移除記錄,主題可能暫留清單。不提供 Truncate:Kafka 依保留策略或各分割區位移移除記錄,兩者均不清空主題。
移動資料
不提供匯入;用 PRODUCE INTO 向主題寫入訊息。將查詢讀取的訊息匯出為 CSV、JSON 或 XLSX。
iPhone 與 iPad
iPhone 與 iPad App 沒有 Apache Kafka 驅動程式。從 Mac 同步的 Apache Kafka 連線會顯示在清單中,但無法開啟。
限制
- 不讀取 Schema Registry,因此 Avro 和 Protobuf 值顯示為原始位元組。
- 不支援建立主題、編輯主題設定或重設消費者群組位移。
- 訊息數量為近似值。
關於 Apache Kafka 的問題
為什麼主題能載入但訊息逾時?
叢集公布了此 Mac 無法存取的位址,如容器主機名稱或私有 IP。請修正 advertised.listeners,或設定 Broker Addresses 僅用啟動位址。
支援 Amazon MSK IAM 登入嗎?
不支援。提供的 SASL 機制為 PLAIN、SCRAM-SHA-256、SCRAM-SHA-512,請在 MSK 叢集建立 SCRAM 使用者,以 SASL_SSL 連線。
取得 TablePro
需要 macOS 13 Ventura 或更新版本