From 5d8fdad20eb23e156cac4ec108eb0ce4c155ae9e Mon Sep 17 00:00:00 2001
From: wangbin <wangbin@emqx.io>
Date: Mon, 11 Oct 2021 17:09:28 +0800
Subject: [PATCH] fix getNormalOffset in SubscriptionOffset

---
 client/src/main/java/io/hstream/SubscriptionOffset.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/io/hstream/SubscriptionOffset.java b/client/src/main/java/io/hstream/SubscriptionOffset.java
index 9dd2ae49..1b545b24 100644
--- a/client/src/main/java/io/hstream/SubscriptionOffset.java
+++ b/client/src/main/java/io/hstream/SubscriptionOffset.java
@@ -43,7 +43,7 @@ public SpecialOffset getSpecialOffset() {
   }
 
   public RecordId getNormalOffset() {
-    if (isSpecialOffset()) {
+    if (isNormalOffset()) {
       return recordId;
     } else {
       throw new IllegalStateException("subscriptionOffset is not normal offset");