在生产者的配置文件中,开发者可以**分区路由的方式。生产者消息发送的响应机制有三个值,0、1和-1,用于设置发送数据是否需要来自服务器的反馈。–0:生成器不会等待代理发送ack。–1:当**收到消息时发送ack。–-1:当所有跟随者成功同步消息时发送ack。request.required.ack=06.消费者的负载平衡当一个消费者加入或离开一个群体时,它将触发分区均衡。均衡的**终目的是提高话题的并发消费能力。步骤如下:1.如果主题1具有以下分区:P0、P1、P2、**2.加入A组的有以下消费者:C0、C13.首先,根据分区索引号对分区进行排序:P0,P1,P2,**。4.按消费者排序。id:C1C05.计算倍数:m=[P0,P1,P2,**]。大小/[C0,C1]。大小,本例中的值是M=2(向上取整)6.然后依次分配分区:C0=[P0,P1],C1=[P2,**],即Ci=[P(i*M),P((i+1)*M-1)]
下一条:深度了解Kafka架构知识
【如果您还没有关注“公司名称”手机网站】