Skip to content

[Bug] Consumer subscription topic is invalid #590

@hagsyn

Description

@hagsyn

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

  1. Directly in the source code test project, when consumers start, give topicList two topics.
    image

  2. The properties : eventMesh.connector.plugin.type=rocketmq

  3. The test sends the message of the first topic, you can see that it is successful, and the consumer has consumed it.

  4. Test sending the message of the following topic, you can see that the controller did not request to come in.

  5. Check rocket-console and find that the message is sent to rocketmq.

image

Debug logs

  1. When the consumer starts, eventmesh-runtime receives the request, you can see that there are two topics.

4433a681318391e1f19b2cefe508f8f

![022ed3e059ad1386a239fcb41d9a0b0](https://user-images.githubusercontent.com/44764414/141777890-73fab4cc-b9c2-4fcd-9c0b-45fb40f8e6f6.png)
  1. Then by locating, you can see that there is only one topic for [eventMeshHTTPServer.localConsumerGroupMapping].
    b60b89143fee6d5e6f0b36e9b84b1a4

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

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions