btlqql opened a new issue, #1045:
URL: https://github.com/apache/rocketmq-dashboard/issues/1045

   ## Problem
   
   `RocketMQAdminClientImpl.sendMessage` creates a throwaway producer whose 
**producer group name** is derived only from `System.currentTimeMillis()`:
   
   ```java
   DefaultMQProducer producer = new DefaultMQProducer("studio_msg_sender_" + 
System.currentTimeMillis());
   ```
   
   Concurrent send requests in the same millisecond build the same group name, 
so two short-lived producers register under one client identity — the same 
collision class that issue caching fixed for consumer/producer *instance names* 
(`ShortLivedClientName`), but the group name is still timestamp-only.
   
   ## Expected
   
   Short-lived producers use a collision-resistant group name while keeping the 
human-readable prefix.
   
   ## Acceptance criteria
   
   - `sendMessage` uses a unique producer group name per call (prefix + random 
suffix).
   - Concurrent sends never share a group identity.
   - Existing functionality (send + audit + shutdown) is unchanged.


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to