Skip to content

Consumer消费失败问题 #121

@107192468

Description

@107192468

目前我有三台metaq和zookeeper提供服务。
Producer1 注册了topic A group testGroup
Producer2 注册了topic B group testGroup
Producer3 注册了topic C group testGroup
Consumer1 extends DefaultMessageListener 订阅了 A,B,
Consumer2 extends DefaultMessageListener 订阅了 A,C
Consumer3 extends DefaultMessageListener 订阅了 B,C

运行一段时间后,一般为2-3天
Consumer3 停止接收消息。
然后手动往topic C发送消息60条,从dashboard可看到Consumer2 消费30条
Consumer3 无消费记录

暂停所有的Consumer,然后在dashboard找到topic C点击条到最后一条记录。

50%的可能性,重新启动Consumer1-3,Consumer3 开始消费
50%的可能性,重启Consumer11-3,发现Consumer3 中显示的pending size 为负数
byte 为负数
暂停所有的Consumer,登陆zookeeper 删除所有的topicC ,重启所有的Consumer
然后可以正常消费。

请问该如何解决该问题?
这是在生产上面的问题,在生产之外测试均未发现该问题。

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions