小编nik*_*610的帖子

我通过新的消费者API创建了kafka消费者
我正在使用kafka 2.10-0.9.0.1
我们有1个消费者群体,每个群体中有1个消费者实例

Kafka脚本'kafka-consumer-groups.sh'提供了删除用户的方法,但这仅适用于旧的使用者组运行命令:

斌/ kafka-consumer-groups.sh

给

--delete:警告:组删除仅适用于旧的基于ZK的使用者组,并且必须小心使用它才能删除不活动的组.

所以我想问一下是否有办法删除通过新的消费者API创建的消费者群组？

我是Kafka的新手,并且使用新的KafkaProducer和KafkaConsumer,版本:0.9.0.1

java中是否有任何方法可以在创建特定主题后更改/更新特定主题的分区数.

我没有使用zookeeper来创建主题.我的KafkaProducer会在发布请求到达时自动创建主题.

如果这些还不够,我还可以提供更多细节