-
Notifications
You must be signed in to change notification settings - Fork 641
Description
Search before asking
- I had searched in the issues and found no similar issues.
Environment
-OS[windows 10] -EventMesh version[1.2.0] -RocketMQ version:[4.5.1]
What happened
When consumers subscribe, the parameters are "url" and "topicList". In fact, only the first topic of topicList takes effect!
How to reproduce
-
Directly in the source code test project, when consumers start, give topicList two topics.

-
The properties : eventMesh.connector.plugin.type=rocketmq
-
The test sends the message of the first topic, you can see that it is successful, and the consumer has consumed it.
-
Test sending the message of the following topic, you can see that the controller did not request to come in.
-
Check rocket-console and find that the message is sent to rocketmq.
Debug logs
- When the consumer starts, eventmesh-runtime receives the request, you can see that there are two topics.
-
Then by locating, you can see that there is only one topic for [eventMeshHTTPServer.localConsumerGroupMapping].

-
It is judged that there is a problem with the put logic here and needs to be optimized.

Are you willing to submit PR?
- Yes I am willing to submit a PR!

