# 消息引擎系统
* 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