aliware-kafka-demos icon indicating copy to clipboard operation
aliware-kafka-demos copied to clipboard

在升级或者宕机时,会发生少量消息乱序(某个分区挂掉后把消息 Failover 到其它分区)是怎么实现的?

Open bosima opened this issue 4 years ago • 3 comments

Producer发送消息的时候不是直接发送到分区所在的broker吗?怎么做到的failover到其它分区? 分区挂掉的时候Producer重新计算了要发送的分区吗?如果是这样,这个是客户端实现的功能吗? 如果发送时指定了分区,指定的分区会被谁自动覆盖掉吗?

bosima avatar Dec 01 '19 13:12 bosima

这个应该就是kafka partition的Failover机制吧,client代码不需要做变动

Guanpx avatar Jan 17 '20 09:01 Guanpx

这个应该就是kafka partition的Failover机制吧,client代码不需要做变动

能不能详细说说,数据不是直接发送到分区的吗?如果会发生乱序,那就是failover时本该发送到崩溃分区的数据发送到了其它分区,这个应该是client做的吧。

bosima avatar Jan 17 '20 10:01 bosima

这个应该就是kafka partition的Failover机制吧,client代码不需要做变动

能不能详细说说,数据不是直接发送到分区的吗?如果会发生乱序,那就是failover时本该发送到崩溃分区的数据发送到了其它分区,这个应该是client做的吧。

可能我理解错了,你问下ali客服?

Guanpx avatar Jan 19 '20 03:01 Guanpx