文档首页 > > 故障排除> 使用Kafka> 新建集群Consumer消费数据失败,提示GROUP_COORDINATOR_NOT_AVAILABLE

新建集群Consumer消费数据失败,提示GROUP_COORDINATOR_NOT_AVAILABLE

分享
更新时间: 2019/11/15 GMT+08:00

问题背景与现象

新建Kafka集群,部署Broker节点数为2,使用Kafka客户端可以正常生产,但是无法正常消费。Consumer消费数据失败,提示GROUP_COORDINATOR_NOT_AVAILABLE,关键日志如下:

2018-05-12 10:58:42,561 | INFO | [kafka-request-handler-3] | [GroupCoordinator 2]: Preparing to restabilize group DemoConsumer with old generation 118 | kafka.coordinator.GroupCoordinator (Logging.scala:68)
2018-05-12 10:59:13,562 | INFO | [executor-Heartbeat] | [GroupCoordinator 2]: Preparing to restabilize group DemoConsumer with old generation 119 | kafka.coordinator.GroupCoordinator (Logging.scala:68)

可能原因

__consumer_offsets无法创建。

原因分析

  1. 查看日志,发现大量__consumer_offset创建异常。
  2. 查看集群发现当前Broker数量为2。
  1. 查看__cosumer_offset topic要求副本为3,因此创建失败。

解决办法

可以将扩容至至少3个流式core节点,或参考如下步骤修改服务配置参数。

  1. 登录到MRS Manager,选择“服务管理 > Kafka > 服务配置”。
  2. “参数类别”选择“全部配置”,搜索并修改offsets.topic.replication.factor和transaction.state.log.replication.factor的值为2。
  3. 单击“保存配置”,勾选“重新启动受影响的服务或实例。”并单击“确定”重启服务。
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区