[ISSUE 4350] Fixed eventmesh startup error under MQ plugin (#4351)

apache · Aug 11, 2023 · 8418745 · 8418745
1 parent dec34f3
commit 8418745
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...mq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java b/...mq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java
@@ -46,7 +46,8 @@ public class RocketMQProducerImpl implements Producer {
 
     @Override
     public synchronized void init(Properties keyValue) {
-        String producerGroup = keyValue.getProperty(Constants.PRODUCER_GROUP);
+        String producerGroup = keyValue.getProperty(Constants.PRODUCER_GROUP)
+            == null ? "RMQ-producerGroup" : keyValue.getProperty(Constants.PRODUCER_GROUP);
 
         String omsNamesrv = clientConfiguration.getNamesrvAddr();
         Properties properties = new Properties();