关闭后消费者重新启动

对于ConsumerImpl api,它支持启动/关闭操作。关机后能否支持重启操作?为什么不支持重新启动操作?

原提问者GitHub用户dumyjob

展开
收起
芬奇福贵 2023-05-26 10:57:36 72 分享 版权
1 条回答
写回答
取消 提交回答
  • 试着运行如下案例,你会发现差异。

    rocketmq/client/src/test/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumerTest.java

    Line 94 in aaa92a2

    public void init() throws Exception {

    原回答者GitHub用户francisoliverlee

    2023-05-26 17:20:41
    赞同 展开评论
问答地址: