update constructor

Signed-off-by: Yashash H L <[email protected]>
numaproj · Mar 21, 2024 · ce1134b · ce1134b
1 parent d55f14a
commit ce1134b
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/main/java/io/numaproj/numaflow/sourcer/Message.java b/src/main/java/io/numaproj/numaflow/sourcer/Message.java
@@ -41,6 +41,18 @@ public Message(byte[] value, Offset offset, Instant eventTime, String[] keys) {
         this(value, offset, eventTime, keys, null);
     }
 
+    /**
+     * used to create Message with value, offset, eventTime and headers.
+     *
+     * @param value message value
+     * @param offset message offset
+     * @param eventTime message eventTime
+     * @param headers message headers
+     */
+    public Message(byte[] value, Offset offset, Instant eventTime, Map<String, String> headers) {
+        this(value, offset, eventTime, null, headers);
+    }
+
     /**
      * used to create Message with value, offset, eventTime, keys and headers.
      *