diff --git a/extensions-contrib/druid-rocketmq/src/main/java/org/apache/druid/firehose/rocketmq/RocketMQFirehoseFactory.java b/extensions-contrib/druid-rocketmq/src/main/java/org/apache/druid/firehose/rocketmq/RocketMQFirehoseFactory.java
index ce78180145b..377a98e365c 100644
--- a/extensions-contrib/druid-rocketmq/src/main/java/org/apache/druid/firehose/rocketmq/RocketMQFirehoseFactory.java
+++ b/extensions-contrib/druid-rocketmq/src/main/java/org/apache/druid/firehose/rocketmq/RocketMQFirehoseFactory.java
@@ -404,6 +404,7 @@ public class RocketMQFirehoseFactory implements FirehoseFactory<InputRowParser<B
         this.requestsWrite.add(request);
         if (!hasNotified) {
           hasNotified = true;
+          // No need to use notifyAll here since extended class com.alibaba.rocketmq.common.ServiceThread handles it
           notify();
         }
       }