# 消息引擎系統
* Kafka 是一款開源的`消息引擎`系統
* AKA Messaging System
* 官方定義:消息引擎系統是一組規范。企業利用這組規范在不同系統之間傳遞語義準確的消息,實現松耦合的異步式數據傳遞。
* 民間定義:系統 A 發送消息給消息引擎系統,系統 B 從消息引擎系統中讀取 A 發送的消息。
* 兩個重要事實
* 消息引擎傳輸的對象是消息
* 如何傳輸消息屬于消息引擎設計機制的一部分
* Kafka 傳遞的消息使用的是`純二進制的字節序列`
* 常見的消息傳輸方式(i.e. 傳輸協議)
* 點對點模型(i.e. 消息隊列模型)
* 日常生活例子中:電話客服模式
* 發布 / 訂閱模型
* 具有主題(Topic)概念,i.e. 邏輯語義相近的消息容器
* 發送方,i.e. Publisher
* 接收方,i.e. Subscriber
* 該模型可以支持
* 多個 publisher 向相同的 topic 發送消息
* 一個 topic 可以存在多個 subscriber
* 參考生活中:報紙訂閱
* Messaging system 的真實作用:`削峰填谷`
- 概覽
- 入門
- 1. 消息引擎系統
- 2. Kafka 術語
- 3. 分布式流處理平臺
- 4. Kafka “發行版”
- 5. Kafka 版本號
- 基本使用
- 6. 生產集群部署
- 7. 集群參數配置
- 客戶端實踐與原理
- 9. Consumer 分區機制
- 10. Consumer 壓縮算法
- 11. 無消息丟失配置
- 12. 客戶端高級功能
- 13. Producer 管理 TCP
- 14. 冪等生產者和事務生產者
- 15. 消費者組
- 16. 位移主題
- 17. 消費者組重平衡(TODO)
- 18. 位移提交
- 19. CommitFailedException
- 20. 多線程開發者實例
- 21. Consumer 管理 TCP
- 22. 消費者組消費進度監控
- Kafka 內核
- 23. 副本機制
- 24. 請求處理
- 25. Rebalance 全流程
- 26. Kafka 控制器
- 27. 高水位和 Leader Epoch
- 管理與監控
- 28. Topic 管理
- 29. Kafka 動態配置
- 30. 重設消費者組位移
- 31. 工具腳本
- 32. KafkaAdminClient
- 33. 認證機制
- 34. 云下授權
- 35. 跨集群備份 MirrorMaker
- 36. 監控 Kafka
- 37. Kafka 監控框架
- 38. 調優 Kafka
- 39. 實時日志流處理平臺
- 流處理
- 40. Kafka Streams
- 41. Kafka Streams DSL
- 42. Kafka Streams 金融
- Q&A