Async processor: minor utility method added (#71)

Author: laxmanchekka

kafka-streams-framework/src/main/java/org/hypertrace/core/kafkastreams/framework/async/RecordToForward.java

@@ -17,4 +17,17 @@
 public class RecordToForward<K, V> {
   @Nullable private String childName;
   private Record<K, V> record;
+
+  public static <K, V> RecordToForward<K, V> from(String childName, K key, V value) {
+    return from(childName, key, value, System.currentTimeMillis());
+  }
+
+  public static <K, V> RecordToForward<K, V> from(
+      String childName, K key, V value, long timestamp) {
+    return from(childName, new Record<>(key, value, timestamp));
+  }
+
+  public static <K, V> RecordToForward<K, V> from(String childName, Record<K, V> record) {
+    return new RecordToForward<>(childName, record);
+  }
 }

kafka-streams-framework/src/test/java/org/hypertrace/core/kafkastreams/framework/SampleAsyncApp.java

@@ -83,9 +83,7 @@ public List<RecordToForward<String, String>> asyncProcess(String key, String val
     }
     log.info("processing - key: {}, value: {}", key, value);
     Thread.sleep(25);
-    return List.of(
-        new RecordToForward<>(
-            null, new Record<>("out:" + key, "out:" + value, System.currentTimeMillis())));
+    return List.of(RecordToForward.from(null, "out:" + key, "out:" + value));
   }
 }