Apache Kafka
在樹狀結構中按右鍵 ▸ 新增 ▸ Kafka 請求。
| 欄位 | 作用 |
|---|---|
| URL | 以逗號分隔的 broker 清單：hote1:9092,hote2:9092 — 整個字串會先由 Handlebars 解析，之後才被切分 |
| 用戶端 ID | 向 broker 宣告的 clientId |
| 主題 | 主題，任何模式下都需要 |
| 模式 | produce、consume 或 browse |
| 欄位 | 值 |
|---|---|
| SASL 機制 | none、plain、scram-sha-256、scram-sha-512 |
| SASL 使用者 / SASL 密碼 | 密碼接受密鑰類型的值 |
| TLS | 可獨立啟用 — 只開 TLS 而不用 SASL 的 broker，搭配 none 機制即可運作 |
produce 模式
Section titled “produce 模式”鍵、值、訊息標頭，以及選填的分割區。若未明確指定分割區，就會採用 用戶端程式庫的預設分割器。回應會傳回所寫入紀錄的中繼資料：主題、分割區、偏移量。
consume 模式
Section titled “consume 模式”| 欄位 | 作用 |
|---|---|
| 群組 | 消費者的 groupId |
| 起始位置 | earliest、latest 或 specific |
| 指定偏移量 | 一個字串 — Kafka 的偏移量是 64 位元整數 |
| 分割區 | 一個用戶端側的篩選器：分割區的指派仍然由群組決定 |
browse 模式
Section titled “browse 模式”在沒有消費者群組的情況下檢視某個分割區：Restorm 會從裡面取出有限數量的訊息，然後 中斷連線。這個模式下分割區是必填的。
想看看某個主題裡有什麼，又不想建立群組、也不想動到偏移量時，這就是合適的工具。
- Kafka produce — 單次動作，會傳回紀錄的中繼資料；
- Kafka consume — 透過消費者群組訂閱，並在每則訊息時發出一個事件；
- 關閉 Kafka 連線 — 停止消費。
請參閱連線與串流。
五個目標：JavaScript（kafkajs，涵蓋產生與消費）與 kcat（產生、消費，以及不使用
群組的瀏覽）。