kafka消费群组出现Consumer group 'opentsdb_AQJC1' has no active members状态

BLue 发表于: 2021-01-04   最后更新时间: 2021-01-04 15:32:08   5,822 游览

使用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,这是什么原因导致的,怎么去解决这个问题呢,希望得到各位老师的知道,谢谢。

发表于 2021-01-04

消费者组opentsdb_AQJC1没有活跃的成员,意思是opentsdb_AQJC1这个消费者组目前没有人进行消费topic。
你可以使用以下命令进行消费之后,然后再次进行查看。

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --group opentsdb_AQJC1
BLue -> 半兽人 3年前

博主,解决了问题,还需要请教您一下,就是我的场景是我从kafka取出数据插入到数据库,但是数据会出现峰值的情况,插入的速度又跟不上消费的数据导致JVM内存溢出,有什么好的方式去解决这种问题,如果是限制消费的速度,应该去怎么去操作。谢谢。

半兽人 -> BLue 3年前

你在kafka首页,问过相同的问题额,我回答你了。

BLue -> 半兽人 3年前

嗷嗷,谢谢,我使用的kettle做的整个过程,您在kettle中使用过kafka吗,对于这样的问题怎么去解决。

半兽人 -> BLue 3年前

没用过kettle额,你可以先尝试扩大jvm内存去解决,一般调整到达某个高值之后,就会平稳,不会在OOM了(ps:前提是kafka集群主题分区不要随意调整)。

Leon -> 半兽人 3年前

大佬请教一下 .Consumer group xx' has no active members. Warning: Consumer group 'xx' is rebalancing. 我看kafka 日志的时候总看到这两个错误,但是我能确定我是有一个消费者去消费topic 的,只是有消息挤压,请问是消息挤压导致的这个异常么

Leon -> BLue 3年前

请问你是如何解决的

半兽人 -> Leon 3年前

你的这个错误可不是这个问题的呀,仔细看下,不一样。重新提个问题吧

你的答案

查看kafka相关的其他问题或提一个您自己的问题