apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.19k stars 11.67k forks source link

[Bug] 4.9.4版本下,广播模式客户端中断消费 #8252

Open DestinyL opened 4 months ago

DestinyL commented 4 months ago

Before Creating the Bug Report

Runtime platform environment

CentOS 7.8

RocketMQ version

4.9.4

JDK Version

1.8

Describe the Bug

广播模式下,消费消息异常,然后catch到一个不完整堆栈的异常之后,消费消息就中断了 image jstack查看线程,后续都为waiting,猜测是server端推送消息中断,客户端只是waiting等待消费,并没有锁的问题 image 广播模式推送消息机制是否有不完善的设计

Steps to Reproduce

偶发,不能直接复现

What Did You Expect to See?

-

What Did You See Instead?

-

Additional Context

No response

humkum commented 4 months ago

Are there any exception in rocketmq client log?

DestinyL commented 4 months ago

Are there any exception in rocketmq client log? 1.异常信息如图揭示,没有更多堆栈信息,这也是我比较奇怪的地方 2.代码如下,使用log4j2 image

DestinyL commented 4 months ago

Are there any exception in rocketmq client log?

我理解的客户端是我的应用,是否还有其他客户端,.rocketmq_offsets只是消费进度等信息,rocketmq生成的broker等日志并未发现异常

humkum commented 4 months ago

Are there any exception in rocketmq client log?

我理解的客户端是我的应用,是否还有其他客户端,.rocketmq_offsets只是消费进度等信息,rocketmq生成的broker等日志并未发现异常

日志默认在 ~/logs/rocketmqlogs/rocketmq_client.log

DestinyL commented 4 months ago

Are there any exception in rocketmq client log?

我理解的客户端是我的应用,是否还有其他客户端,.rocketmq_offsets只是消费进度等信息,rocketmq生成的broker等日志并未发现异常

日志默认在 ~/logs/rocketmqlogs/rocketmq_client.log image 是否跟上面异常相关呢