分区分配

默认是rangeAssignor 策略,就是根据名字做点取余操作,去均分分区。

当然还有其他的,当然也可以自定义分配策略。

默认分区也是有不好的时候的,比如三个broker,两个主题,每个主题两个分区,这时就会不均衡了。

这就是为什么分区数尽量是 borker 的倍数。

消费者协调器

每个不同消费者如果采取不同的分配策略,那么在同一个消费者组中应该听谁的呢?

那么在 broker 中选了一个作为大哥,这个 borker 里面记录了 group**这个东西,这个 group会告诉消费者组应该采取哪种分配策略。(好像就是投票,本消费者组中的哪种策略采用的多)

事务

消息中间件有三种情况:消息重复,消息丢失,消息整好不多不少完美的被消费掉。

幂等性,就是对于生产的消息,发送失败了,重试后,不会发生消息重复的问题。

Untitled

上面那样设置一下就 ok。