使用kafka-tool查看kafka消费群组发现有一个消费群组看不到offset,发现该消费群组显示 no active:
在shell 查看消费群组:
./kafka-consumer-groups.sh --bootstrap-server --group opentsdb_AQJC1 --describe
**Consumer group 'opentsdb_AQJC1' has no active members.**
出现 Consumer group 'opentsdb_AQJC1' has no active members
,这是什么原因导致的,怎么去解决这个问题呢,希望得到各位老师的知道,谢谢。
消费者组
opentsdb_AQJC1
没有活跃的成员,意思是opentsdb_AQJC1
这个消费者组目前没有人进行消费topic。你可以使用以下命令进行消费之后,然后再次进行查看。
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --group opentsdb_AQJC1
博主,解决了问题,还需要请教您一下,就是我的场景是我从kafka取出数据插入到数据库,但是数据会出现峰值的情况,插入的速度又跟不上消费的数据导致JVM内存溢出,有什么好的方式去解决这种问题,如果是限制消费的速度,应该去怎么去操作。谢谢。
你在kafka首页,问过相同的问题额,我回答你了。
嗷嗷,谢谢,我使用的kettle做的整个过程,您在kettle中使用过kafka吗,对于这样的问题怎么去解决。
没用过kettle额,你可以先尝试扩大jvm内存去解决,一般调整到达某个高值之后,就会平稳,不会在OOM了(ps:前提是kafka集群主题分区不要随意调整)。
大佬请教一下 .Consumer group xx' has no active members. Warning: Consumer group 'xx' is rebalancing. 我看kafka 日志的时候总看到这两个错误,但是我能确定我是有一个消费者去消费topic 的,只是有消息挤压,请问是消息挤压导致的这个异常么
请问你是如何解决的
你的这个错误可不是这个问题的呀,仔细看下,不一样。重新提个问题吧
你的答案