楼主,您好, 我现在遇到一个问题.
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 都不在同一组中。
谢谢