diff --git a/metadata/src/main/java/org/apache/kafka/controller/stream/StreamControlManager.java b/metadata/src/main/java/org/apache/kafka/controller/stream/StreamControlManager.java
index a41378094e..f53ae12655 100644
--- a/metadata/src/main/java/org/apache/kafka/controller/stream/StreamControlManager.java
+++ b/metadata/src/main/java/org/apache/kafka/controller/stream/StreamControlManager.java
@@ -743,13 +743,15 @@ public ControllerResult<CommitStreamObjectResponseData> commitStreamObject(Commi
                     .min(Long::compareTo).get();
         }
 
-        // generate stream object record
-        records.add(new ApiMessageAndVersion(new S3StreamObjectRecord()
-                .setObjectId(streamObjectId)
-                .setStreamId(streamId)
-                .setStartOffset(startOffset)
-                .setEndOffset(endOffset)
-                .setDataTimeInMs(dataTs), (short) 0));
+        if (streamObjectId != NOOP_OBJECT_ID) {
+            // generate stream object record
+            records.add(new ApiMessageAndVersion(new S3StreamObjectRecord()
+                    .setObjectId(streamObjectId)
+                    .setStreamId(streamId)
+                    .setStartOffset(startOffset)
+                    .setEndOffset(endOffset)
+                    .setDataTimeInMs(dataTs), (short) 0));
+        }
 
         // generate compacted objects' remove record
         if (sourceObjectIds != null && !sourceObjectIds.isEmpty()) {