產品介紹
# 前言
本文檔為金蝶Apusic分散式訊息佇列for Kafka（Apusic Distributed Message Queue，簡稱：ADMQ for Kafka）的產品介紹，幫助使用者快速了解ADMQ for Kafka產品的功能、技術特性及典型應用場景。
# 適用對象
本文檔適用於IT資訊化業務負責人、研發經理、軟體專案經理、軟體架構師、運維工程師。
# 相關文件
了解更多 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
您在取得技術支援時，請提供如下資訊：
您的姓名
公司資訊與聯絡方式
作業系統及其版本
產品版本號
出現異常及錯誤的日誌、截圖等詳細資訊
# 產品簡介
# 產品定位
金蝶Apusic分散式訊息佇列for Kafka（Apusic Distributed Message Queue，簡稱：ADMQ for Kafka）是專為Kafka使用者打造的信創替代型雲原生訊息中介軟體，完全遵循 Kafka 核心架構設計與特性規範，實現協定、用戶端、生態工具、業務場景的全相容，無需改造即可替代原有 Kafka 叢集，滿足信創專案落地需求。
# 核心價值
遵循 Kafka 分散式、高吞吐、低延遲的核心特性，同時適配信創軟硬體環境，提供更穩定的運作保障、更便捷的運維支援及更全面的安全能力，成為 Kafka 信創替代的優選方案。
# 核心能力
| 核心能力 | 解釋 |
|---|---|
| Kafka 協定完全相容 | 完整實現 Kafka 生產消費協定、分割區分配協定、Offset 管理協定、叢集協調協定等核心協定，行為與原生 Kafka 一致。 |
| 全版本用戶端適配 | 支援 Java、Go、Python、C++ 等 Kafka 官方用戶端（2.x-3.x 版本）及第三方開源用戶端，無需改造即可接入。 |
| 生態工具無縫複用 | 相容 Kafka-console-producer/consumer、kafka-topics.sh、kafka-configs.sh 等原生工具，支援 Kafka Connect、MirrorMaker 等資料同步工具。 |
| 信創環境深度適配 | 適配主流信創作業系統（麒麟、統信等）、信創晶片（ARM、RISC-V 等），相容信創資料庫及中介軟體生態。 |
| Kafka 核心特性繼承 | 支援主題分割區、副本機制、消費者群組、訊息壓縮、Offset 提交（自動 / 手動）等 Kafka 原生核心特性。 |
# 產品架構
# 架構概述
ADMQ for Kafka產品採用 Kafka 經典分散式架構，完全遵循 Kafka 通訊協定與儲存模型。產品整體架構分為管控台、核心引擎和分散式協調三大模組，具備高可靠、高可用、可擴充的特性。
# 管控台（Console）
- 管控台是面向運維人員和管理員的可視化操作介面，提供全生命週期管理能力：
- 叢集管理：對訊息叢集節點進行接入和狀態監控。
- 使用者權限：基於角色的存取控制（RBAC），保障操作安全。
- 主題管理：建立、刪除、設定訊息主題（Topic），管理分割區和副本。
- 訂閱管理：管理消費者群組（Consumer Group）、訂閱關係和消費位點。
- 訊息檢索：支援按時間、Key、內容等條件查詢歷史訊息。
# 核心引擎（Core Engine）
核心引擎是訊息處理的核心，相容 Kafka 協定，保障訊息的可靠傳輸與儲存：
Kafka 協定接入 & 安全存取控制
提供標準 Kafka 協定相容層，支援現有 Kafka 用戶端無縫遷移。
整合認證（如 SASL）、授權和傳輸加密（SSL/TLS），保障存取安全。
訊息處理服務
訊息生產接入：接收生產者（Producer）發送的訊息，進行校驗和路由。
訊息消費服務：向消費者（Consumer）推送或拉取訊息，支援順序消費和批次消費。
訊息持久化儲存：將訊息寫入磁碟，支援高吞吐寫入和高效檢索，保證資料不遺失。
元資料服務：管理主題、分割區、副本、消費者群組等元資料資訊，確保叢集狀態一致。
高可用與負載管理
多副本同步：透過多副本機制（如 ISR）保證資料冗餘，防止單點故障。
故障復原與副本遷移：節點故障時自動切換，支援副本在叢集內遷移以平衡負載。
負載平衡：將生產和消費請求均勻分配到叢集節點，提升整體吞吐量。
狀態監控：即時監控節點、分割區和副本的健康狀態，為故障復原提供依據。
# 分散式協調（Distributed Coordination）
分散式協調模組（基於金蝶 Apusic 分散式設定中心）負責維護叢集的一致性和狀態：
叢集成員管理：維護叢集中所有 Broker 節點的線上／離線狀態。
元資料持久儲存：儲存並同步主題、分割區、副本分配等核心元資料。
Controller 選舉：在叢集中選舉出 Controller 節點，負責分割區管理和故障處理。
分割區 Leader 選舉：當分割區 Leader 節點故障時，自動從 Follower 中選舉新的 Leader。
叢集狀態監聽通知：當叢集狀態（如節點上下線、Leader 變更）發生變化時，向相關元件發送通知，觸發相應處理。
# 產品優勢
零改造信創替代：無需修改業務程式碼、無需調整用戶端配置（僅需變更連線地址），即可直接替代原有 Kafka 叢集，遷移成本趨近於零。
生態完全相容：Kafka 原生工具、監控系統（Prometheus+Grafana）、資料同步工具等均可直接複用，無需額外適配開發。
信創環境適配：全面相容信創軟硬體生態，滿足政企信創專案落地要求，提供端到端的信創解決方案。
特性原汁原味：完全遵循 Kafka 核心特性規範，支援使用者熟悉的所有業務場景（如高吞吐資料傳輸、串流資料處理等），業務無感知切換。
安全合規增強：在保留 Kafka 原有安全能力基礎上，新增安全特性，符合信創專案安全合規標準。
# 應用場景
- 信創專案替代場景：政企信創改造中，直接替代原有 Kafka 叢集，無需重構業務系統，快速滿足信創落地要求。
- 高吞吐資料傳輸場景：如日誌採集、業務資料同步等，繼承 Kafka 高吞吐特性，支撐海量資料即時傳輸。
- 串流資料處理場景：相容 Flink、Spark Streaming 等串流計算引擎，無縫對接原有串流資料處理鏈路。
- 分散式系統解耦場景：基於 Kafka 原生的發布訂閱模式，實現分散式系統間非同步通訊，降低系統耦合度。