HZL3151904214 opened a new issue, #1085:
URL: https://github.com/apache/rocketmq-client-go/issues/1085
集群环境，部署了三套环境共有三个broker每个broker有8个queue，测试过程中发现有一个broker的queue会一直堆积消息没法正常消费，其他的queue都可以正常消费，看客户端控制台也没有warn与error日志，是什么原因？
把客户端重启后可以正常消费，但是具体是什么原因导致的某个queue堆积不消费没分析出来，并没有大量消息生产，只是少量的消息，主要还是小概率问题。。
consumer的配置如下：
c, err := rocketmq.NewPushConsumer(
consumer.WithGroupName(config.YMQConfig.Consumer.ConsumerGroupName),
consumer.WithConsumerOrder(true),
consumer.WithNameServer(strings.Split(config.YMQConfig.ServerAddress, ",")),
consumer.WithInstance(generateInstanceName()),
consumer.WithCredentials(primitive.Credentials{
AccessKey: config.YMQConfig.AccessKey,
SecretKey: config.YMQConfig.SecretKey,
}),
consumer.WithConsumeFromWhere(consumer.ConsumeFromLastOffset),
consumer.WithConsumerModel(consumer.Clustering),
consumer.WithRebalanceLockInterval(1*time.Second),
)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
