同样是逻辑上的概念,是Kafka实现单播和广播两种消息模型的手段。同一个topic的数据,会 广播给不同的group;同一个group中的worker,只有一个worker能拿到这个数据。换句话 说,对于同一个topic,每个group都可以拿到同样的所有数据,但是数据进入group后只能被其中的一个worker消费。group内的worker可以使用多线程或多进程来实现,也可以将进程分散在多台机器上,worker的数量通常不超过partition的数量,且二者最好保持整数倍关 系,因为Kafka在设计时假定了一个partition只能被一个worker消费(同一group内)。