kafka多个consumer同时消费一个topic数据

 

需求：一个topic消息队列设置3个partitions分区，设置一个goup组中3个consumer进行消费

注意点：一个group中的consumer数 需小于 topic中的partitions分区数（一个partitions只能被一个consumer进行消费；一个consumer可以消费多个partitions）

kafka命令：

         查看topic详情：./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

         修改topic分区：./bin/kafka-topics.sh --alter --zookeeper localhost:2181 --topic test --partitions 5