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");