[Bug] java.lang.ClassCastException: org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext cannot be cast to org.apache.eventmesh.storage.rocketmq.patch.EventMeshConsumeConcurrentlyContext

[likehao19]

Search before asking

• I had searched in the issues and found no similar issues.

Environment

Windows

EventMesh version

1.10.0

What happened

2025-12-04 09:27:43,217 INFO [ConsumeMessageThread_eventmesh-ConsumerGroup-1996127417273421826_7] EventMeshMessageListenerConcurrently(EventMeshMessageListenerConcurrently.java:63) - handleMessage fail
java.lang.ClassCastException: org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext cannot be cast to org.apache.eventmesh.storage.rocketmq.patch.EventMeshConsumeConcurrentlyContext
at org.apache.eventmesh.storage.rocketmq.patch.EventMeshMessageListenerConcurrently.consumeMessage(EventMeshMessageListenerConcurrently.java:44) [eventmesh-storage-rocketmq-1.10.0-release.jar:1.10.0-release]
at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:402) [rocketmq-client-4.9.5.jar:4.9.5]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
2025-12-04 09:27:44,204 INFO [MQClientFactoryScheduledThread] RocketmqClient(Slf4jLoggerFactory.java:100) - send heart beat to broker[localhost.localdomain 0 10.10.83.100:10911] success
2025-12-04 09:27:44,204 INFO [MQClientFactoryScheduledThread] RocketmqClient(Slf4jLoggerFactory.java:85) - HeartbeatData [clientID=10.10.83.100@8654%EventMesh%14169808631206000, producerDataSet=[ProducerData [groupName=CLIENT_INNER_PRODUCER], ProducerData [groupName=eventmesh-ProducerGroup-551749c2-ad13-44f1-b708-02ed7a8aff63]], consumerDataSet=[]]
2025-12-04 09:27:44,506 DEBUG [pool-7-thread-1] ConsumerManager(LogUtils.java:84) - grpc client info check
2025-12-04 09:27:44,506 DEBUG [pool-7-thread-1] ConsumerManager(LogUtils.java:90) - total number of ConsumerGroupClients: 0

How to reproduce

use eventstore version: rocketmq4.9.5

Debug logs

2025-12-04 09:27:43,217 INFO  [ConsumeMessageThread_eventmesh-ConsumerGroup-1996127417273421826_7] EventMeshMessageListenerConcurrently(EventMeshMessageListenerConcurrently.java:63) - handleMessage fail
java.lang.ClassCastException: org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext cannot be cast to org.apache.eventmesh.storage.rocketmq.patch.EventMeshConsumeConcurrentlyContext
	at org.apache.eventmesh.storage.rocketmq.patch.EventMeshMessageListenerConcurrently.consumeMessage(EventMeshMessageListenerConcurrently.java:44) [eventmesh-storage-rocketmq-1.10.0-release.jar:1.10.0-release]
	at org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService$ConsumeRequest.run(ConsumeMessageConcurrentlyService.java:402) [rocketmq-client-4.9.5.jar:4.9.5]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_202]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_202]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_202]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_202]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_202]
2025-12-04 09:27:44,204 INFO  [MQClientFactoryScheduledThread] RocketmqClient(Slf4jLoggerFactory.java:100) - send heart beat to broker[localhost.localdomain 0 10.10.83.100:10911] success
2025-12-04 09:27:44,204 INFO  [MQClientFactoryScheduledThread] RocketmqClient(Slf4jLoggerFactory.java:85) - HeartbeatData [clientID=10.10.83.100@8654%EventMesh%14169808631206000, producerDataSet=[ProducerData [groupName=CLIENT_INNER_PRODUCER], ProducerData [groupName=eventmesh-ProducerGroup-551749c2-ad13-44f1-b708-02ed7a8aff63]], consumerDataSet=[]]
2025-12-04 09:27:44,506 DEBUG [pool-7-thread-1] ConsumerManager(LogUtils.java:84) - grpc client info check
2025-12-04 09:27:44,506 DEBUG [pool-7-thread-1] ConsumerManager(LogUtils.java:90) - total number of ConsumerGroupClients: 0

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct *

[nagarjunahp88-byte]

Hi, I would like to work on this issue.
I am currently analyzing the ClassCastException related to ConsumerContext handling and trying to identify where the unsafe type casting happens.
I will update this issue once I have more findings.
Thanks!

[nagarjunahp88-byte]

Update: I searched the codebase and realized that ConsumerContext does not exist in EventMesh.
Sorry for the confusion earlier.

I’m continuing to investigate the issue and will update once I locate the correct consume context and code path.
Thanks for your patience.