管控台使用者手冊
# 前言
本文檔為金蝶 Apusic 分散式訊息佇列 for Kafka（Apusic Distributed Message Queue，簡稱：ADMQ for Kafka）管控台產品的使用者手冊，詳細介紹 ADMQ for Kafka 產品 Web 管控台的功能使用、配置方法及管理操作等內容。
# 適用對象
本文檔適用於 IT 資訊化業務負責人、研發經理、軟體專案經理、軟體架構師、運維工程師。
# 相關文檔
瞭解更多 ADMQ for Kafka 產品相關的資訊，請參閱以下 ADMQ for Kafka 產品手冊文檔集：
| 序號 | 手冊文檔 | 說明 |
|---|---|---|
| 1 | 金蝶 Apusic 分散式訊息佇列 for Kafka 快速使用手冊 | 簡單介紹了如何快速上手使用 ADMQ for Kafka。 |
| 2 | 金蝶 Apusic 分散式訊息佇列 for Kafka 安裝手冊 | 詳細介紹如何在各作業系統上安裝 ADMQ for Kafka，以及 ADMQ for Kafka 服務啟停等操作。 |
| 3 | 金蝶 Apusic 分散式訊息佇列 for Kafka 訊息引擎使用者手冊 | 詳細介紹 ADMQ for Kafka 訊息引擎相關功能的使用、配置、管理及配套工具的使用方法。 |
| 4 | 金蝶 Apusic 分散式訊息佇列 for Kafka 管控台使用者手冊 | 詳細介紹 ADMQ for Kafka 管控台相關功能的使用和操作說明。 |
| 5 | 金蝶 Apusic 分散式訊息佇列 for Kafka 開發手冊 | 詳細介紹基於各開發語言進行 ADMQ for Kafka 用戶端應用開發的說明。 |
| 6 | 金蝶 Apusic 分散式訊息佇列 for Kafka 遷移手冊 | 詳細介紹從 Kafka 遷移到 ADMQ for Kafka 的說明。 |
| 7 | 金蝶 Apusic 分散式訊息佇列 for Kafka 運維手冊 | 詳細介紹 ADMQ for Kafka 的監控、運維、安全加固等運維說明。 |
| 8 | 金蝶 Apusic 分散式訊息佇列 for Kafka 效能最佳化手冊 | 詳細介紹 ADMQ for Kafka 效能調優的說明。 |
# 技術支援
ADMQ for Kafka 產品提供全面的技術支援服務，您可以透過以下方式獲得技術支援：
- 網址：www.apusic.com
- 電話：400-855-5800
- 郵箱：support@apusic.com
- 金蝶雲社群：https://vip.kingdee.com/?productId=73&productLineId=14&lang=zh-CN
您在取得技術支援時，請提供如下資訊：
- 您的姓名
- 公司資訊與聯絡方式
- 作業系統及其版本
- 產品版本號
- 出現異常及錯誤的日誌、截圖等詳細資訊
# 版本變更說明
| 版本 | 日期 | 變更說明 |
|---|---|---|
| V2.0.6 | 2026-06-23 | 新增 ADMQ for Kafka 管控台使用者手冊，涵蓋管理面入口、主題管理、訂閱群組管理、使用者與 ACL 管理、訊息查詢、監控與統計、常見問題及附錄等內容。 |
# 概述
金蝶 Apusic 分散式訊息佇列 for Kafka（Apusic Distributed Message Queue，簡稱：ADMQ for Kafka）管控台是面向 ADMQ for Kafka 叢集的 Web 管理介面，分為系統管理與運維管理兩側。
- 系統管理側：主要用於核心引擎的接入、叢集配置、使用者管理及權限配置。管理員需先在系統管理側完成 Kafka 服務節點（Broker）叢集的接入與對接。
- 運維管理側：用於日常叢集運維，包括主題、訂閱群組、使用者、ACL、訊息查詢及監控統計等操作。接入完成後，運維人員可登入運維管理側檢視引擎狀態並進行管理維護。
使用者需先進入系統管理側進行叢集配置與對接，然後在運維管理側進行叢集管理。
# 安裝和運行
# 運行環境
ADMQ for Kafka 管控台基於 Java Web 技術構建，運行前請確認已滿足以下環境要求：
| 項目 | 要求 |
|---|---|
| JDK | JDK 1.8 及以上 |
| CPU | 建議 2 核及以上 |
| 記憶體 | 建議 4 GB 及以上 |
| 磁碟 | 根據訊息保留策略與叢集規模預留足夠空間 |
| 瀏覽器 | 推薦 Chrome、Firefox、Edge 等主流瀏覽器的最新版本 |
| 網路 | 管控台伺服器需能存取 Kafka 叢集的 JMX 連接埠及管理連接埠 |
關於 ADMQ for Kafka 管控台的完整安裝、啟動、停止及升級步驟，請參閱《金蝶 Apusic 分散式訊息佇列 for Kafka 安裝手冊》。
# 管理面入口
# 存取位址
在瀏覽器網址列輸入以下 URL 進入 ADMQ 管控台登入頁面：
http://{console_ip}:12305
其中 {console_ip} 為管控台伺服器 IP 位址。
# 登入流程
第 1 步： 開啟瀏覽器，輸入上述存取位址，進入登入頁面。
第 2 步： 輸入預設帳號與密碼。系統首次安裝後，預設管理員帳號為 admq。
第 3 步： 首次登入時，系統會強制要求修改初始密碼。請按頁面提示設定複雜度符合要求的新密碼，並妥善保存。
第 4 步： 登入成功後，根據帳號權限進入系統管理側或運維管理側。
安全注意事項：首次登入後請立即修改預設密碼，避免使用弱密碼；生產環境建議為不同角色分配最小必要權限，並定期審計 ACL 規則與使用者權限。
# 預設帳號與權限
| 帳號 | 初始密碼 | 所屬角色 | 權限說明 |
|---|---|---|---|
| admq | admq（首次登入需修改） | 系統管理員 | 擁有系統管理側與運維管理側的完整權限，可進行叢集接入、使用者管理、ACL 配置及所有運維操作 |
一般使用者帳號由管理員在【使用者管理】中建立，權限透過 ACL 規則進行細粒度控制。
# 介面佈局簡介
登入後，管控台介面分為左右兩側：
- 系統管理側：左側導覽包含叢集管理、使用者管理、ACL 管理等，用於引擎接入、叢集配置、權限與安全設定。
- 運維管理側：左側導覽包含資源管理（主題、訂閱群組）、訊息查詢、監控運維（監控儀表板、訊息統計報表）等，用於日常叢集運維與監控。
頁面頂部通常包含叢集選擇器、全域搜尋及個人中心等通用入口。
# 主題管理
# 功能入口
【資源管理】-【主題】
# 檢視主題列表
支援按以下條件篩選：
- 主題類型：一般主題 / 系統主題
- 名稱：按主題名稱模糊搜尋
列表欄位說明：
| 欄位 | 說明 |
|---|---|
| 名稱 | 主題名稱，點選可進入詳情頁，支援一鍵複製 |
| 類型 | 一般主題 / 系統主題 |
| 分割區數 | 該主題的分割區數量 |
| 不同步副本數 | 當前副本未完全同步的分割區數量（大於 0 表示存在可用性風險） |
| 副本數 | 每個分割區的副本數量 |
| 訊息數量 | 主題下所有分割區的訊息總數 |
| 儲存佔用 | 主題訊息佔用的磁碟空間大小 |
| 描述 | 描述資訊 |
# 建立主題
點選列表右上角的 "新增" 按鈕，開啟主題新建頁面：
在 基本配置 區域填寫：
配置項 必填 說明 主題名稱 是 只能包含英文、數字、 _、-、.，長度不超過 128 字元分割區數量 是 正整數，建議根據並發量設定，至少 1。預設值為 6 分割區副本數 是 選擇叢集預設或自訂數量（1 ~ Broker 數量，建議 ≥ 2） 訊息保留時間 是 訊息在主題中的保留時長，單位毫秒。快速選項：1小時、8小時、24小時、7天（預設）、30天 最大儲存大小 是 主題訊息佔用的最大磁碟空間限制。預設"不限制"（-1 GB） 清理策略 是 單選：刪除（預設）/ 壓縮 / 壓縮&刪除 主題備註 否 描述資訊，最多 160 字元 在 常用參數 區域可選配置：
參數 預設值 說明 訊息時間戳類型 (message.timestamp.type) CreateTime 訊息時間戳的產生方式 是否允許從非同步副本選舉 (unclean.leader.election.enable) false 是否允許不在同步副本集合（In-Sync Replicas，ISR）中的副本成為主副本（Leader） 日誌段滾動時間間隔 (segment.ms) 引擎預設值 日誌段按時間滾動的間隔 單條訊息最大允許大小 (max.message.bytes) 引擎預設值 單條訊息的最大位元組數 在 自訂參數 區域，有經驗的運維人員可新增和修改進階參數：
⚠️ 自訂參數僅限於有經驗的運維人員新增和修改。預設配置參數優先於自訂參數。
點選右下角 "確定" 儲存，或點選 "取消" 放棄。
注意事項：
- 分割區數建立後只能增加，不能減少。
- 副本因子建立後不可修改。
- 系統內部主題（如
__consumer_offsets）不允許修改。
# 傳送訊息
點選行末的 "傳送訊息" 按鈕，可向指定主題傳送測試訊息：
- Key：訊息的鍵，用於分割區路由（相同 Key 的訊息會進入同一分割區）
- Value：訊息內容
- 選擇分割區：可選，指定傳送到哪個分割區；不指定時按 Key 的雜湊路由
- Headers：可選，用於存放和訊息內容無關的中繼資料
此功能常用於除錯和驗證主題是否正常工作。
# 複製主題
點選行末的 "複製" 按鈕，可基於已有主題的配置快速建立新主題：
- 系統會自動填入原主題的分割區數、副本因子等配置
- 只需修改名稱即可快速建立
# 編輯主題
點選行末的 "編輯" 按鈕，可修改主題描述資訊。
主題名稱、分割區數（不支援減少）、副本因子建立後不可修改。
# 刪除主題
點選行末的 "刪除" 按鈕，確認後刪除。刪除主題將同時刪除該主題下的所有訊息，請謹慎操作。
系統內部主題不可刪除。
# 清空主題
點選行末的 "清空" 按鈕，將刪除該主題所有分割區中的訊息。此操作不可復原，請謹慎使用。
# 批次操作
透過列表左側的核取方塊選擇多個主題後，可進行批次操作：
- 批次刪除：同時刪除選中的多個主題
- 批次重平衡：同時進行多個主題重平衡
# 同步主題
點選 "同步" 按鈕，可將 Kafka 叢集中實際存在的主題與平台資料庫進行比對和同步：
- 系統將展示差異預覽：新增（叢集有但平台無）、刪除（平台有但叢集無）、更新（雙方存在差異）
- 勾選需要同步的項目，點選 "確認同步"
建議在叢集有變更（如透過其他工具建立了主題）後執行同步，確保平台資料與叢集一致。
# 主題詳情
點選主題名稱，進入詳情頁，可檢視該主題的詳細資訊：
# 分割區資訊
展示各分割區的基本資訊：
- 分割區 ID
- Leader 副本所在 Broker
- ISR（同步副本列表）
- 起始偏移量 / 最新偏移量
- 訊息數量
# 訊息列表
展示該主題各分割區中的訊息，支援按分割區篩選，可檢視訊息的 Key、Value、偏移量、時間戳等資訊。
# 配置資訊
展示主題的詳細配置參數，如清理策略（delete/compact）、保留時間、段大小等。
# 訂閱資訊
展示消費該主題的訂閱群組列表及各消費群的消費進度（每個分割區的當前偏移量）。
# 擴充分割區
當主題的訊息量增加，需要提升並行消費能力時，可以對主題進行擴容：
- 在主題列表中，點選行末的 "擴容" 按鈕
- 輸入新的分割區數（必須大於當前分割區數）
- 點選 "確認"
擴容後，已有的訊息不會重新分佈到新分割區，只有新訊息會按新的分割區數路由。
# 訂閱群組管理
# 功能入口
【資源管理】-【訂閱群組】
# 檢視訂閱群組列表
支援按名稱模糊搜尋。列表欄位說明：
| 欄位 | 說明 |
|---|---|
| 名稱 | 訂閱群組名稱，點選可進入詳情頁，支援一鍵複製 |
| 描述 | 描述資訊 |
| 成員數 | 當前線上的消費者執行個體數量 |
| 訂閱主題數 | 該組訂閱的主題數量 |
| 消費延遲數 | 該組累計的消費延遲（Lag）總數，即未消費訊息數 |
| 所屬節點 | 該訂閱群的協調器（Coordinator）所在 Broker 節點 |
| 狀態 | 消費中 / 準備重平衡 / 正在重平衡 / 失效 / 空閒 |
# 狀態說明
| 狀態 | 說明 |
|---|---|
| 消費中（Stable） | 消費者正常消費訊息 |
| 準備重平衡（PreparingRebalance） | 有消費者加入或離開，正在準備重新分配分割區 |
| 正在重平衡（CompletingRebalance） | 分割區分配方案已確定，正在完成重平衡 |
| 失效（Dead） | 訂閱群組已失效，無活躍消費者 |
| 空閒（Empty） | 訂閱群組存在但目前無消費者 |
# 建立訂閱群組
- 點選列表右上角的 "新增" 按鈕
- 填寫表單：
- 名稱（必填）：訂閱群組唯一識別，建立後不可修改
- 描述（可選）
- 點選 "確認" 儲存
訂閱群組名稱建立後不可修改。
# 編輯訂閱群組
點選行末的 "編輯" 按鈕，可修改訂閱群組的描述資訊。
# 刪除訂閱群組
點選行末的 "刪除" 按鈕，確認後刪除。刪除訂閱群組將清除該組的偏移量記錄，請謹慎操作。
# 同步訂閱群組
點選 "同步" 按鈕，可將 Kafka 叢集中實際存在的訂閱群組與平台資料庫進行比對和同步。
# 訂閱群組詳情
點選訂閱群組名稱，進入詳情頁，可檢視該訂閱群組的詳細資訊
# 訂閱資訊
展示該組訂閱的所有主題及各主題在各分割區的消費進度。
# 消費者列表
展示當前線上的消費者執行個體：
- 分割區名稱
- 消費者名稱
- 位址
- 訊息延遲
- 當前偏移量
- 最新偏移量
# 重設偏移量
當需要重新消費歷史訊息或跳過部分訊息時，可以重設訂閱群組的消費偏移量：
在訂閱群組列表中，點選行末的 "重設偏移量" 按鈕。
選擇重設策略：
- 重設到最早：消費位點回到各分割區的最早訊息
- 重設到最新：消費位點跳到各分割區的最新訊息
- 重設到指定時間：消費位點回到指定時間戳對應的位置
選擇分割區
點選 "確認"
重設偏移量會影響所有正在執行的消費者，請確保業務可接受重複消費或訊息遺失。
# 使用者管理
# 功能入口
【使用者】-【使用者管理】
# 檢視使用者列表
列表欄位說明：
| 欄位 | 說明 |
|---|---|
| 使用者名稱 | 使用者識別 |
| 認證方式 | SCRAM-SHA-256 / SCRAM-SHA-512 等 |
| 描述 | 描述資訊 |
| 狀態 | 正常 / 已刪除 |
# 建立使用者
點選列表右上角的 "新增" 按鈕
填寫表單：
- 使用者名稱（必填）：使用者唯一識別，建立後不可修改
- 密碼（必填）：至少 6 位字元
- 描述（可選）
點選 "確認" 儲存
# 編輯使用者
點選行末的 "編輯" 按鈕，可修改使用者密碼和描述資訊。
使用者名稱建立後不可修改。
# 刪除使用者
點選行末的 "刪除" 按鈕，確認後刪除。刪除使用者後，使用該使用者認證的用戶端連線將被中斷。
# 同步使用者
點選 "同步" 按鈕，可將 Kafka 叢集中實際存在的使用者與平台資料庫進行比對和同步。
同步邏輯與主題/訂閱群組同步相同，用於解決平台資料與叢集實際狀態不一致的問題。
# ACL 管理
# 功能入口
【使用者】-【ACL管理】
# 檢視 ACL 列表
列表欄位說明：
| 欄位 | 說明 |
|---|---|
| 資源類型 | Topic / Group / Cluster / TransactionalId / DelegationToken |
| 資源名稱 | 具體的資源識別 |
| 匹配模式 | LITERAL（精確匹配）/ PREFIXED（前綴匹配） |
| Principal | 被授權的使用者，格式為 User:使用者名稱 |
| 操作權限 | Read / Write / Create / Delete / Alter / Describe / All |
| 權限類型 | ALLOW（允許）/ DENY（拒絕） |
| Host | 允許存取的來源主機，* 表示所有主機 |
# 建立 ACL
- 點選列表右上角的 "新增" 按鈕
- 填寫表單：
- 資源類型（必填）：選擇要控制的資源類型
- 資源名稱（必填）：資源的具體名稱
- 匹配模式（必填）：LITERAL 或 PREFIXED
- Principal（必填）：格式為
User:使用者名稱 - 操作權限（必填）：選擇允許的操作
- Host（必填）：
*表示所有主機，或指定具體 IP - 效力（必填）：ALLOW 或 DENY
- 點選 "確認" 儲存
ACL 規則範例：
- 允許使用者
app-producer向主題app-logs寫入訊息：資源類型=Topic，資源名稱=app-logs，Principal=User:app-producer，操作權限=Write，效力=ALLOW- 拒絕使用者
test-user存取所有主題：資源類型=Topic，資源名稱=*，匹配模式=PREFIXED，Principal=User:test-user，操作權限=All，效力=DENY
安全提示：請遵循最小權限原則，僅為使用者分配完成任務所需的最小權限集合，並優先使用精確匹配（LITERAL）而非前綴匹配（PREFIXED），以降低誤授權風險。
# 編輯 ACL
點選行末的 "編輯" 按鈕，可修改 ACL 規則的所有欄位。
# 刪除 ACL
點選行末的 "刪除" 按鈕，確認後刪除該 ACL 規則。
# 同步 ACL
點選 "同步" 按鈕，可將 Kafka 叢集中實際存在的 ACL 規則與平台資料庫進行比對和同步。
建議在進行權限變更或排查權限問題時執行同步。
# 訊息查詢
# 功能入口
【訊息查詢】-【訊息查詢】
# 查詢訊息
- 選擇要查詢的主題
- （可選）選擇具體的分割區，不選則查詢該主題的所有分割區
- 設定查詢條件：
- 偏移量範圍：按起始偏移量和結束偏移量篩選
- 時間範圍：按訊息時間戳篩選
- Key 過濾：按訊息 Key 模糊匹配
- 點選 "查詢" 按鈕
查詢結果列表欄位說明：
| 欄位 | 說明 |
|---|---|
| 偏移量 | 訊息在分割區中的偏移量 |
| 所屬分割區 | 訊息所在的分割區 ID |
| 訊息時間 | 訊息的時間戳 |
| Key | 訊息的鍵 |
| Value | 訊息的內容（長度限制顯示） |
# 檢視訊息詳情
點選行末的 "檢視訊息" 按鈕，可檢視訊息的完整內容，包括：
- 主題、訊息大小、時間戳
- Key 和 Value 的完整內容
- 訊息頭（Headers）資訊
# 匯出訊息
點選行末的 "匯出" 按鈕，可將單條訊息匯出為檔案。
批次匯出功能可透過訊息統計報表模組實現。
# 使用建議
- 訊息查詢功能主要用於排查問題和驗證訊息內容，不建議作為常規的資料消費方式。
- 查詢大量訊息時，建議縮小時間範圍或指定具體分割區，以提高查詢效率。
- 訊息的 Value 可能經過序列化（如 JSON、Avro、Protobuf），檢視時請注意格式轉換。
# 監控與統計
# 監控儀表板
# 功能入口
【監控運維】-【監控儀表板】
# 時間範圍選擇
頁面頂部提供時間範圍選擇器，支援快速選項（最近1小時、最近6小時、最近1天等）和自訂時間範圍。
# 監控維度
監控儀表板分為四個標籤頁：
# 叢集
展示叢集整體運行狀況，包括：
- Broker（線上/總數）：當前線上 Broker 數量和總 Broker 數量
- 主題數：叢集中 Topic 總數
- 分割區數：叢集中 Partition 總數
- 訊息流入速率：叢集整體訊息生產速率（條/秒）
- 訊息吞吐量趨勢圖：生產/消費速率隨時間變化曲線
# 節點
展示各節點的資源使用情況：
- 節點列表：分割區數、Leader 數、日誌目錄大小、JVM 記憶體使用/上限、CPU 使用率、連線數
- 選中節點後展示趨勢圖：訊息速率、位元組流入/流出速率、請求速率等
# 主題
展示主題相關的監控指標（需選擇具體主題）：
- 訊息生產速率（條/秒）
- 位元組流入速率（位元組/秒）
- 位元組流出速率（位元組/秒）
- 儲存大小（位元組）
- 訊息總量（條）
- 分割區數（個）
- 副本不足分割區數（個）
# 訂閱群組
展示訂閱群組相關的監控指標（需選擇具體訂閱群組）：
- 訊息消費速率（條/秒）
- 訊息堆積數量（條）
- 按 Topic 堆積（條）
- 消費者成員數（個）
監控資料來源於 Kafka Java 管理擴展（Java Management Extensions，JMX）指標，資料重新整理頻率約為 5 秒。
# 訊息統計報表
# 功能入口
【監控運維】-【訊息統計報表】
# 檢視統計結果
支援兩種統計維度：
- 叢集維度：按日期聚合整個叢集的訊息指標
- Topic 維度：按日期 + Topic 聚合訊息指標
統計指標包括：
| 指標 | 說明 |
|---|---|
| 生產訊息數 | 生產者發佈到叢集/Topic 的訊息數量 |
| 消費訊息數 | 消費者從叢集/Topic 消費的訊息數量 |
| 入站位元組數 | 流入叢集的總位元組數 |
| 出站位元組數 | 流出叢集的總位元組數 |
# 匯出報表
點選 "匯出" 按鈕，可將當前查詢結果匯出為 Excel 檔案。
# 統計任務
如需按固定週期（如每小時、每天）自動統計訊息資料，請聯絡管理員配置定時統計任務。
# 常見問題
# Q1: 為什麼建立了主題但在列表中看不到？
可能原因：
- 叢集選擇器 —— 檢查是否選擇了正確的 Kafka 叢集
- 資料未同步 —— 如果透過其他工具直接建立了主題，需點選 "同步" 按鈕將資料同步到平台
- 篩選條件 —— 檢查是否設定了主題類型等篩選條件
# Q2: 消費者消費速度慢，訊息堆積嚴重怎麼辦？
- 進入 監控儀表板 → 訂閱群組，檢視該消費群的 Lag 趨勢
- 檢查消費者執行個體數量是否足夠，考慮增加消費者執行個體
- 如果消費者數已達到分割區數上限，考慮對主題進行擴容（增加分割區數）
- 檢查消費者程式碼是否存在效能瓶頸（如單條訊息處理時間過長）
# Q3: 如何檢視某個訂閱群組的消費進度？
- 進入 訂閱群組 頁面
- 點選訂閱群組名稱進入詳情頁
- 在"訂閱資訊"標籤頁中，檢視各分割區目前的消費偏移量與最新偏移量的對比
# Q4: 傳送訊息時如何選擇分割區？
- 不指定分割區 + 有 Key：按 Key 的雜湊值路由到對應分割區（相同 Key 的訊息進入同一分割區）
- 不指定分割區 + 無 Key：按輪詢策略分配分割區
- 指定分割區：訊息直接進入指定分割區
# Q5: 同步按鈕的作用是什麼？
同步功能用於解決平台資料與 Kafka 叢集實際狀態不一致的問題。場景包括：
- 透過 Kafka 命令列工具或其他管理介面直接操作了叢集資源
- 叢集發生故障復原後資料不一致
- 首次接入已有資料的叢集
同步會比對平台資料庫和叢集實際狀態，展示差異並支援選擇性同步。
# Q6: 主題的分割區數可以縮減嗎？
不可以。Kafka 的分割區數只能增加，不能減少。這是 Kafka 的設計限制，因為減少分割區會導致已有訊息的歸屬混亂。
如果分割區數設定過多，建議建立新主題並遷移資料。
# Q7: ACL 規則的優先級是怎樣的？
Kafka ACL 的匹配優先級如下：
- 精確匹配優先於前綴匹配（LITERAL > PREFIXED）
- DENY 優先於 ALLOW
建議遵循最小權限原則，僅為使用者分配必要的權限。
# 附錄
# 術語表
| 術語 | 說明 |
|---|---|
| Topic（主題） | Kafka 中訊息的邏輯分類單元，生產者發送訊息到指定主題，消費者從主題訂閱訊息 |
| Partition（分割區） | 主題的物理分片，一個主題可包含多個分割區，分割區是 Kafka 並行處理的基本單位 |
| Broker（Kafka 服務節點） | Kafka 叢集中的單個服務節點，負責接收、儲存和轉發訊息 |
| ISR（In-Sync Replicas，同步副本集合） | 與主副本保持同步的副本集合，只有 ISR 中的副本才有資格被選為主副本 |
| Leader（主副本） | 分割區的主副本，負責處理該分割區的所有讀寫請求 |
| Consumer Group（消費群組） | 一組共同消費一個或多個主題的消費者執行個體，群組內消費者協調分配分割區 |
| Offset（偏移量） | 訊息在分割區中的唯一識別，消費者透過偏移量記錄消費位置 |
| JMX（Java Management Extensions，Java 管理擴展） | Java 平台標準監控與管理介面，ADMQ for Kafka 透過 JMX 暴露運行指標 |
| ACL（Access Control List，存取控制列表） | Kafka 的權限控制機制，用於限制使用者或用戶端對資源的操作權限 |
| Rebalance（重平衡） | 消費群組成員發生變化時，重新分配分割區的過程 |
| Lag（消費延遲） | 消費者當前偏移量與分割區最新偏移量之間的差值，表示未消費訊息數 |
# 配置參考表
| 參數/配置項 | 預設值 | 說明 |
|---|---|---|
num.partitions | 6 | 主題預設分割區數 |
default.replication.factor | 1 | 主題預設副本數 |
retention.ms | 604800000（7 天） | 訊息保留時長，單位為毫秒 |
log.retention.bytes | -1 | 日誌保留最大位元組數，-1 表示不限制 |
cleanup.policy | delete | 日誌清理策略，可選 delete / compact / compact&delete |
max.message.bytes | 1000012 | 單條訊息最大允許位元組數 |
message.timestamp.type | CreateTime | 訊息時間戳類型，可選 CreateTime / LogAppendTime |
unclean.leader.election.enable | false | 是否允許非 ISR 副本選舉為 Leader |
segment.ms | 604800000（7 天） | 日誌段按時間滾動的間隔 |
min.insync.replicas | 1 | 生產者請求成功所需的最小 ISR 數量 |