cnScarb

[Question] Why eventmesh re-write RocketMQ's consume serivce and use a global thread pool to consume all messages?

3

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/eventmesh/issues?q=is%3Aissue) and found no similar issues. ### Question I'm new to Eventmesh, after reading some source code of Eventmesh,...

**Describe the bug** https://github.com/streamnative/aop/blob/06bf6573172c2c41fb0483215ce65ccea5b281a7/amqp-impl/src/main/java/io/streamnative/pulsar/handlers/amqp/impl/PersistentExchange.java#L287-L303 in `removeQueue` method, we remove value from a map when iterating it, which cause potential ConcurrentModificationException. **To Reproduce** bind queue with Direct exchange, then remove the...

 谷歌和必应没有该问题

[ISSUE #8137] Support pop consumption for light message queue

1

### Which Issue(s) This PR Fixes Fixes #8137 ### Brief Description Support server-side rebalance for light message queues. Add light message queue consume demos. ### How Did You Test This...

[Enhancement] Add peek API support

1

### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Add client API support for...

[ISSUE #5844] Fix bug when examine pop consumer group info

2

**Make sure set the target branch to `develop`** ## What is the purpose of the change Fix #5844 ## Brief changelog Use `examineBrokerClusterInfo` instead of examine retry topic route info...

### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Support pop consumption for light...

[ISSUE #8025] fix: fix topic route when topic deleted

1

### Which Issue(s) This PR Fixes Fixes #8025 ### Brief Description 1. make `getTopicRouteInfoFromNameServer` return null when the topic not exist and allow the topic not exist 2. remove the...

### Before Creating the Bug Report - [X] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions). - [X] I have searched the...

### Which Issue(s) This PR Fixes Fixes #8753 ### Brief Description Ref: #4568 ### How Did You Test This Change? 1. Set mappedFileSizeCommitLog to 102400. 2. Create 3 topics: TopicTest1...