diff --git a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java b/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java
index 9ef760617c..d38e9d30d8 100644
--- a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java
+++ b/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java
@@ -75,10 +75,9 @@ public void handle(ConnectRecord record) {
                 sendRecordToUrl(record, attributes, url);
                 break;
             case BROADCAST:
-                for (URI broadcastUrl : urls) {
-                    attributes.put(MultiHttpRequestContext.NAME, new MultiHttpRequestContext(urls.size()));
-                    sendRecordToUrl(record, attributes, broadcastUrl);
-                }
+                attributes.put(MultiHttpRequestContext.NAME, new MultiHttpRequestContext(urls.size()));
+                // send the record to all URLs
+                urls.forEach(url0 -> sendRecordToUrl(record, attributes, url0));
                 break;
             default:
                 throw new IllegalArgumentException("Unknown delivery strategy: " + deliveryStrategy);