1个partition只能被同组的一个consumer消费，同组的consumer则起到均衡效果 消费者多于partition topic： test 只有一个partition 创建一个topic——test， 在g2组中启动两个 ...

正文前先来一波福利推荐： 福利一： 百万年薪架构师视频，该视频可以学到很多东西，是本人花钱买的VIP课程，学习消化了一年，为了支持一下女朋友公众号也方便大家学习，共享给大家。 福利二： 毕业 ...

分区和消费组是kafka提高性能的主要方式，其理念为多组件协作，共同完成数据读写任务，两者的相关原理及关系如下： 一：分区 kafka的数据层级为：主题->分区->消息。即：kafka可有多个主题，每个主题可以有多个分区，每个分区可以有多条消息。 这里是分区概念类似于数据库sql ...

首先要注意的是，Kafka 中的 Topic 和 ActiveMQ 中的 Topic 是不一样的。 在 Kafka 中，Topic 是一个存储消息的逻辑概念，可以认为是一个消息集合。每条消息发送到 Kafka 集群的消息都有一个类别。物理上来说，不同的 Topic 的消息是分开存储 ...

...

通常一个分区由一个消费者消费，或者说由一个组中的一个消费。 有一种情况，分区数多，且只有一个消费者时，分组的话，消息会被组中唯一一个消费者线性消费，不会发生争抢。因为消息能被组中一个消费者线性消费。 不分组的话会消息都会被消费者拉过去。 ...

在 Kafka 中无论是 producer 往 topic 中写数据, 还是 consumer 从 topic 中读数据, 都避免不了和 offset 打交道, 关于 offset 主要有以下几个概念。 Last Committed Offset：consumer group 最新一次 ...

1、消费方式 　　consumer 采用 pull（拉） 模式从 broker 中读取数据。　　push（推）模式很难适应消费速率不同的消费者，因为消息发送速率是由 broker 决定的。　　它的目标是尽可能以最快速度传递消息，但是这样很容易造成 consumer 来不及处理消息，尚硅谷 ...