触发日志压缩-am运行0.9.0并使用log.cleaner.enable=true重新启动后,我的使用者不再工作。
如果我跑了 /kafka-consumer-groups.sh kafka-groups.sh --bootstrap-server 10.211.16.215 --group groupX --describe
我明白了
org.apache.kafka.common.errors.NotCoordinatorForGroupException: This is not the correct coordinator for this group.
有什么线索可以解决这个问题。我可以重新启动经纪人,但作为一个生产系统,我喜欢确保它将解决或不会产生进一步的问题。
任何帮助都将不胜感激
暂无答案!
目前还没有任何答案,快来回答吧!