Skip to content

Commit e3fd91a

Browse files
authored
fix subscriptionFromGrpc (#164)
1 parent dfb53ea commit e3fd91a

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

client/src/main/java/io/hstream/util/GrpcUtils.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,7 @@ public static Subscription subscriptionFromGrpc(io.hstream.internal.Subscription
6767
return Subscription.newBuilder().subscription(subscription.getSubscriptionId()).stream(
6868
subscription.getStreamName())
6969
.ackTimeoutSeconds(subscription.getAckTimeoutSeconds())
70+
.maxUnackedRecords(subscription.getMaxUnackedRecords())
7071
.offset(subscriptionOffsetFromGrpc(subscription.getOffset()))
7172
.createdTime(Instant.ofEpochSecond(createdTime.getSeconds(), createdTime.getNanos()))
7273
.build();

0 commit comments

Comments
 (0)