kafka多个consumer同时消费一个topic数据
需求：一个topic消息队列设置3个partitions分区，设置一个group组中3个consumer进行消费注意点：一个group中的consumer数 需小于 topic中的partitions分区数（一个partitions只能被一个consumer进行消费；一个consumer可以消费多个partitions）kafka命令：查看topic详情：./bin/kafka-topics.sh
·
需求：一个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
华为开发者空间，是为全球开发者打造的专属开发空间，汇聚了华为优质开发资源及工具，致力于让每一位开发者拥有一台云主机，基于华为根生态开发、创新。
更多推荐
0
0- 0
已为社区贡献3条内容
所有评论(0)