44[ ![ Maven Central] ( https://img.shields.io/maven-central/v/io.hstream/hstreamdb-java )] ( https://search.maven.org/artifact/io.hstream/hstreamdb-java )
55[ ![ javadoc] ( https://javadoc.io/badge2/io.hstream/hstreamdb-java/javadoc.svg )] ( https://javadoc.io/doc/io.hstream/hstreamdb-java )
66[ ![ Snapshot Artifacts] ( https://img.shields.io/nexus/s/https/s01.oss.sonatype.org/io.hstream/hstreamdb-java.svg )] ( https://s01.oss.sonatype.org/content/repositories/snapshots/io/hstream/hstreamdb-java/0.5.0-SNAPSHOT/ )
7- [ ![ javadoc] ( https://javadoc.io/badge2/io.hstream/hstreamdb-java/0.5 .0-SNAPSHOT/javadoc.svg )] ( https://hstreamdb.github.io/hstreamdb-java/javadoc/ )
7+ [ ![ javadoc] ( https://javadoc.io/badge2/io.hstream/hstreamdb-java/0.6 .0-SNAPSHOT/javadoc.svg )] ( https://hstreamdb.github.io/hstreamdb-java/javadoc/ )
88
99This is the offical Java client library for [ HStreamDB] ( https://hstream.io/ ) .
1010
1111** Please use the latest released version.**
1212
13- ** The latest release is v0.4 .0, which requires hstream server v0.5.2 .**
13+ ** The latest release is v0.5 .0, which requires hstream server v0.5.3 .**
1414
1515## Content
1616- [ Installation] ( #installation )
@@ -38,7 +38,7 @@ For Maven Users, the library can be included easily like this:
3838 <dependency >
3939 <groupId >io.hstream</groupId >
4040 <artifactId >hstreamdb-java</artifactId >
41- <version >${hstreamdbClient.version} </version >
41+ <version >0.5.0 </version >
4242 </dependency >
4343</dependencies >
4444
@@ -50,7 +50,7 @@ For Gradle Users, the library can be included easily like this:
5050
5151``` groovy
5252
53- implementation 'io.hstream:hstreamdb-java:${hstreamdbClientVersion} '
53+ implementation 'io.hstream:hstreamdb-java:0.5.0 '
5454
5555```
5656
@@ -140,12 +140,15 @@ batchedProducer.flush()
140140
141141``` java
142142// first, create a subscription for the stream
143- Subscription subscription =
144- new Subscription (
145- " my_subscription" ,
146- " test_stream" ,
147- new SubscriptionOffset (SubscriptionOffset . SpecialOffset . LATEST ));
148- client. createSubscription(subscription);
143+ Subscription subscription =
144+ Subscription
145+ .newBuilder()
146+ .subscription(" my_subscription" )
147+ .stream(" my_stream" )
148+ .offset(new SubscriptionOffset (SubscriptionOffset . SpecialOffset . LATEST ))
149+ .ackTimeoutSeconds(600 )
150+ .build();
151+ client. createSubscription(subscription);
149152
150153// second, create a consumer attach to the subscription
151154Consumer consumer =
0 commit comments