跳至主要內容

每天都用 TablePro?購買授權即可使用付費功能,並支持下一版本的開發。 購買授權購買授權,支持 TablePro

適用於 Mac 的 Apache Kafka 用戶端

用 KafkaQL 從所選起點讀取主題,查看每個消費者群組的延遲,並產生測試訊息。主題是記錄,所以格線僅讀取訊息,從不編輯。

適用於 Mac首次選擇 Apache Kafka 時下載驅動程式

針對 orders 主題的 KafkaQL CONSUME 陳述式,訊息按分割區、位移、索引鍵和時間戳記列出。

概覽

查詢語言
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

Mac App 可免費下載和使用。Starter 或 Team 方案新增選用功能。
下載 Mac 版

需要 macOS 13 Ventura 或更新版本