快速了解Kafka

快速上手Kafka

• 启动zookeeper

• 启动kafka

• 创建topic - 启动发送者 - 启动消费者

Partition 0:  [msg1] -> [msg2] -> [msg3] -> ...
                0        1        2

Partition 1:  [msg4] -> [msg5] -> ...
                0        1

• 同一个消费者组中对同一个消息只会消费一次，但是不同的消费者组可以都对一条消息进行消费

• 不同的消费者组会记录自己的一个消费记录offset

理解Kafka的集群

• Broker：Kafka 的服务器实例。
• Partition：一个 Topic 被划分的最小单位。
• Leader Partition：每个 Partition 都有一个 Leader，负责处理读写请求。
• Follower Partition：其余副本称为 Follower，从 Leader 同步数据，主要用于容错。

Kafka集群的消息流转模型