业务客户端程序没有重新平衡消费者?这个在创建消费者的时候,需要传什么配置吗,我现在的消费者客户端配置如下:
properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, littlecConfig.getConfig(KAFKA_HOST));
properties.put(ConsumerConfig.GROUP_ID_CONFIG, KAFKA_GROUP);
properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
properties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
没有重新平衡消费者,可能是什么原因
要看下对应分区的消费组情况。
## 显示某个消费组的消费详情(0.9版本 - 0.10.1.0 之前)
bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group test-consumer-group
## 显示某个消费组的消费详情(0.10.1.0版本+)
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
另外,现在消费者业务重启之后,也看不出来了。
主要是为了看是否消费者组是否有消费者占用分区,但并没有消费,如果是这种,很可能是业务客户端程序没有重新平衡消费者。