当使用消费者组时,您需要确保消费者组名称相同。 您可以检查以下几点:

  1. 您的消费者组名称是否正确
  2. 您的消费者是否已经成功地加入了消费者组
  3. 您的消费者是否正确地订阅了主题

如果您确定消费者组名称正确,并且您的消费者正确地订阅了主题,但仍无法获取消费者信息,则可能存在其他问题。

您可以尝试使用 Sarama 的消费者组管理 API 来检查消费者组的健康状况。 例如,您可以检查消费者组的偏移量是否正确,并且消费者是否处于活动状态。 以下是使用 Sarama 管理消费者组的示例代码:

config := sarama.NewConfig()
config.Consumer.Group.Rebalance.Strategy = sarama.BalanceStrategyRange
consumerGroup, err := sarama.NewConsumerGroup([]string{brokerAddress}, 'my-group', config)
if err != nil {
    log.Fatal(err)
}

go func() {
    for err := range consumerGroup.Errors() {
        log.Error(err)
    }
}()

go func() {
    for range consumerGroup.Notifications() {
        log.Info('Rebalanced')
    }
}()

handler := MyConsumerHandler{}

for {
    err := consumerGroup.Consume(context.Background(), []string{'my-topic'}, &handler)
    if err != nil {
        log.Error(err)
    }
}

在此示例中,我们使用 Sarama 的 NewConsumerGroup 函数创建一个消费者组对象。 然后,我们使用 Consume 函数启动消费者组。 我们还为消费者组设置了一个自定义的处理程序(MyConsumerHandler),它将处理从主题中接收到的消息。 最后,我们使用 Errors 和 Notifications 函数监视消费者组的状态。

Go Kafka Sarama: 消费者组无法获取消费者信息问题排查

原文地址: https://www.cveoy.top/t/topic/lys5 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录