kafka中partition和消费者对应关系

1个partition只能被同组的⼀个consumer消费，同组的consumer则起到均衡效

果

消费者多于partition

topic： test 只有⼀个partition

创建⼀个topic——test，

在g2组中启动两个consumer，

消费者数量为2⼤于partition数量1，此时partition和消费者进程对应关系如

下：

消费者consumer-1-fd7b120f-fd21-4e07-8c23-87b71c1ee8a5⽆对应的partition。

⽤图表⽰为

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic

1. bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --

2. bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group g2

TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID

test 0 9 9 0 consumer-1-4a2a4aa8-32f4-4904-9c16-1c0bdf7128a2 /127.0.0.1 consumer-1

- - - - - consumer-1-fd7b120f-fd21-4e07-8c23-87b71c1ee8a5 /127.0.0.1 consumer-1

kafka中partition和消费者对应关系1