chore: release version 0.7.0 (#103)

Signed-off-by: Yashash H L <[email protected]> Signed-off-by: Keran Yang <[email protected]> Co-authored-by: Keran Yang <[email protected]>
numaproj · Mar 26, 2024 · 9ae5641 · 9ae5641
1 parent 3dae164
commit 9ae5641
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 6 deletions.
diff --git a/README.md b/README.md
@@ -26,7 +26,7 @@ Add this dependency to your project's POM:
 <dependency>
   <groupId>io.numaproj.numaflow</groupId>
   <artifactId>numaflow-java</artifactId>
-  <version>0.6.0</version>
+  <version>0.7.0</version>
 </dependency>
 ```
 
@@ -35,7 +35,7 @@ Add this dependency to your project's POM:
 Add this dependency to your project's build file:
 
 ```groovy
-compile "io.numaproj.numaflow:numaflow-java:0.6.0"
+compile "io.numaproj.numaflow:numaflow-java:0.7.0"
 ```
 
 ```

diff --git a/examples/pom.xml b/examples/pom.xml
@@ -17,7 +17,7 @@
         <dependency>
             <groupId>io.numaproj.numaflow</groupId>
             <artifactId>numaflow-java</artifactId>
-            <version>0.6.0</version>
+            <version>0.7.0</version>
         </dependency>
 
         <dependency>

diff --git a/examples/src/main/java/io/numaproj/numaflow/examples/source/simple/SimpleSource.java b/examples/src/main/java/io/numaproj/numaflow/examples/source/simple/SimpleSource.java
@@ -10,8 +10,10 @@
 import io.numaproj.numaflow.sourcer.Sourcer;
 
 import java.time.Instant;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
 
 /**
@@ -41,12 +43,17 @@ public void read(ReadRequest request, OutputObserver observer) {
             if (System.currentTimeMillis() - startTime > request.getTimeout().toMillis()) {
                 return;
             }
+
+            Map<String, String> headers = new HashMap<>();
+            headers.put("x-txn-id", UUID.randomUUID().toString());
+
             // create a message with increasing offset
             Offset offset = new Offset(Longs.toByteArray(readIndex));
             Message message = new Message(
                     Long.toString(readIndex).getBytes(),
                     offset,
-                    Instant.now());
+                    Instant.now(),
+                    headers);
             // send the message to the observer
             observer.send(message);
             // keep track of the messages read and not acknowledged

diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>io.numaproj.numaflow</groupId>
     <artifactId>numaflow-java</artifactId>
-    <version>0.6.0</version>
+    <version>0.7.0</version>
     <packaging>jar</packaging>
 
     <name>numaflow-java</name>
@@ -24,7 +24,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <protobuf.version>3.21.8</protobuf.version>
         <grpc.version>1.59.0</grpc.version>
-        <netty.version>4.1.100.Final</netty.version> <!-- match version grpc-netty depends on -->
+        <netty.version>4.1.108.Final</netty.version> <!-- match version grpc-netty depends on -->
         <akka.version>2.8.1</akka.version>
         <slf4j.version>2.0.7</slf4j.version>
     </properties>