yanglifan opened a new issue #2123: URL: https://github.com/apache/rocketmq/issues/2123
In the test environment, messages of one topic may have different versions. And consumers of this topic are same too, also have different versions. And the message should be send to the consumer which has the same version. **e.g., the message v1 of the topic A should be send to the consumer v1 if it existed in some of consumer groups, or any consumer can process the versioned message if there is no versioned consumer of some consumer groups.** We already has an internal mechanism to support this requirement based on the message selection/allocation, but I hope to have a discussion to create a common solve this issue. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org