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

需求:一个topic消息队列设置3个partitions分区,设置一个group组中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

上一篇:kafka生产者Producer、消费者Consumer的拦截器interceptor


下一篇:kafka java api