返回到文章

采纳

编辑于

kafka发布订阅模式下,第一个consumer 消费信息时间大概100ms, 但最后一个consumer消费却需要6s左右

kafka

楼主,您好, 我现在遇到一个问题.

情况描述:

1、有1000个consumer 去消费同一个topic中的信息, 当1000个consumer不在同一组时,采用pub-sub模式时, 第一个consumer 消费信息时间大概100ms, 但最后一个consumer消费却需要6s左右, 该怎么解决呢?

2、如何使用queue模式, 一个topic采用partitions 1000, 代码该如何写, 如何实现呢?

测试场景:

PC-1: KAFKA服务器,
PC-2: producer端,
PC-3: eclipse 中跑 1000 个 consumer,采用pub-sub模式,consumers 都不在同一组中。

谢谢