kafka简介
💡
原文中文，约3300字，阅读约需8分钟。
📝
内容提要
本文介绍了Kafka的核心组件和工作方式，包括Producer、Consumer、Topic、Broker和Partition等。Kafka使用Consumer Group实现消息的广播和单播，支持多个Consumer Group。Producer负责消息分发，可以配置分发方式和服务端反馈。Consumer Group的加入和离开会触发负载均衡，提升并发消费能力。
🎯
关键要点
- Kafka是一个分布式流处理平台，核心组件包括Producer、Consumer、Topic、Broker和Partition。
- Producer负责生成消息并发送到Broker，Consumer从Broker消费消息。
- Topic是消息的分类目录，Broker是Kafka服务器的实例，Zookeeper用于保存元信息。
- Kafka的数据处理步骤包括Producer发送消息、Broker接收并写入Topic、备份到Follower Broker、Consumer消费消息。
- Consumer Group用于实现消息的广播和单播，一个Topic可以有多个Consumer Group。
- 每个Consumer Group中的Consumer可以并发消费消息，提高故障容错性。
- Kafka保证同一Partition中的消息顺序，但不保证多个Partition间的全局顺序。
- Producer通过Socket直接将消息发送到Broker，消息路由方式可配置。
- Producer的消息发送应答机制有三种设置：0、1、-1，分别对应不同的确认策略。
- Consumer的负载均衡在Consumer加入或离开时触发，旨在提升并发消费能力。
➡️
