Fix error message for getOffset

Signed-off-by: xiaolongran <[email protected]>
streamnative · Jul 2, 2021 · 1082884 · 1082884
1 parent 136b518
commit 1082884
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...mq-impl/src/main/java/org/streamnative/pulsar/handlers/rocketmq/utils/MessageIdUtils.java b/...mq-impl/src/main/java/org/streamnative/pulsar/handlers/rocketmq/utils/MessageIdUtils.java
@@ -53,7 +53,7 @@ public static final long getOffset(long ledgerId, long entryId, long partitionId
 
         Preconditions.checkArgument(ledgerId <= MAX_LEDGER_ID, "ledgerId has overflow in rop.");
         Preconditions.checkArgument(entryId <= MAX_ENTRY_ID, "entryId has overflow in rop.");
-        Preconditions.checkArgument(partitionId <= MAX_PARTITION_ID, "entryId has overflow in rop.");
+        Preconditions.checkArgument(partitionId <= MAX_PARTITION_ID, "partitionId has overflow in rop.");
         ledgerId = ledgerId + 1L;
         entryId = entryId + 1L;
         partitionId = partitionId + 1;