sync the examples with version 0.4.0 (#24)

Author: Yu-zh

README.md

@@ -6,11 +6,11 @@
 
 This is the offical Java client library for [HStreamDB](https://hstream.io/).
 
-**Please use the latest released version.** 
+**Please use the latest released version.**
 
-**The latest release is v0.3.0, which requires hstream server v0.5.2 .**
+**The latest release is v0.4.0, which requires hstream server v0.5.2 .**
 
-## Content 
+## Content
 - [Installation](#installation)
     - [Maven](#maven)
     - [Gradle](#gradle)
@@ -23,7 +23,7 @@ This is the offical Java client library for [HStreamDB](https://hstream.io/).
 
 ## Installation
 
-The library artifact is published in Maven central, 
+The library artifact is published in Maven central,
 available at [hstreamdb-java](https://search.maven.org/artifact/io.hstream/hstreamdb-java).
 
 ### Maven
@@ -42,7 +42,7 @@ For Maven Users, the library can be included easily like this:
 
 ```
 
-### Gradle 
+### Gradle
 
 For Gradle Users, the library can be included easily like this:
 
@@ -52,7 +52,7 @@ implementation 'io.hstream:hstreamdb-java:${hstreamdbClientVersion}'
 
 ```
 
-## Example Usage 
+## Example Usage
 
 ### Connect to HStreamDB
 
@@ -71,11 +71,11 @@ public class ConnectExample {
 
 ```
 
-### Work with Streams 
+### Work with Streams
 
 ```java
 
-// get a list of streams 
+// get a list of streams
 for(Stream stream: client.listStreams()) {
   System.out.println(stream.getStreamName());
 }
@@ -90,7 +90,7 @@ client.deleteStream("test_stream");
 
 ```
 
-### Write Data to a Stream 
+### Write Data to a Stream
 
 ```java
 
@@ -134,7 +134,7 @@ batchedProducer.flush()
 **Please do not write both binary data and hrecord in one stream.**
 
 
-### Consume Data from a Stream 
+### Consume Data from a Stream
 
 ```java
 // first, create a subscription for the stream
@@ -162,7 +162,7 @@ consumer.startAsync().awaitRunning();
 
 ```
 
-### Process Data in Stream with SQL   
+### Process Data in Stream with SQL
 
 ```java
 
@@ -183,15 +183,15 @@ Observer<HRecord> observer =
         public void onCompleted() {}
       };
 
-// second, create a queryer to execute a sql 
+// second, create a queryer to execute a sql
 Queryer queryer =
       client
           .newQueryer()
           .sql("select * from test_stream emit changes;")
           .resultObserver(observer)
           .build();
 
-// third, start the queryer 
+// third, start the queryer
 queryer.startAsync().awaitRunning();
 
 ```

examples/README.md

@@ -3,7 +3,7 @@
 ## Prerequisites 
 
 - hstreamdb server [v0.5.2.0](https://hub.docker.com/layers/hstreamdb/hstream/v0.5.2.0/images/sha256-d26234758cd47916d6a5d137a3690cdeeddaf7af041a8eea5e7c1d7ada43f3b8)
-- hstreamdb-java [v0.3.0](https://search.maven.org/artifact/io.hstream/hstreamdb-java/0.3.0/jar) 
+- hstreamdb-java [v0.4.0](https://search.maven.org/artifact/io.hstream/hstreamdb-java/0.4.0/jar) 
 
 ## Examples
 

examples/app/build.gradle

@@ -10,7 +10,7 @@ repositories {
 }
 
 dependencies {
-    implementation 'io.hstream:hstreamdb-java:0.3.0'
+    implementation 'io.hstream:hstreamdb-java:0.4.0'
 }
 
 application {

examples/app/src/main/java/io/hstream/example/ConsumerExample.java

@@ -14,14 +14,10 @@ public static void main(String[] args) {
     client.createStream(DEMO_STREAM);
 
     Subscription subscription =
-        Subscription.newBuilder()
-            .setSubscriptionId(DEMO_SUBSCRIPTION)
-            .setStreamName(DEMO_STREAM)
-            .setOffset(
-                SubscriptionOffset.newBuilder()
-                    .setSpecialOffset(SubscriptionOffset.SpecialOffset.EARLIST)
-                    .build())
-            .build();
+        new Subscription(
+            DEMO_SUBSCRIPTION,
+            DEMO_STREAM,
+            new SubscriptionOffset(SubscriptionOffset.SpecialOffset.LATEST));
     client.createSubscription(subscription);
 
     Producer producer =