diff --git a/core/src/main/java/kafka/automq/failover/FailoverListener.java b/core/src/main/java/kafka/automq/failover/FailoverListener.java
index 16f4b8dcea..1d482952a9 100644
--- a/core/src/main/java/kafka/automq/failover/FailoverListener.java
+++ b/core/src/main/java/kafka/automq/failover/FailoverListener.java
@@ -80,11 +80,11 @@ private Optional<FailoverContext[]> getContexts(MetadataDelta delta) {
             .map(kv -> kv.get(FailoverConstants.FAILOVER_KEY))
             .map(this::decodeContexts);
     }
-
+    
     private FailoverContext[] decodeContexts(ByteBuffer byteBuffer) {
-        byteBuffer.slice();
-        byte[] data = new byte[byteBuffer.remaining()];
-        byteBuffer.get(data);
+        ByteBuffer slice = byteBuffer.slice();
+        byte[] data = new byte[slice.remaining()];
+        slice.get(data);
         return JsonUtils.decode(new String(data, StandardCharsets.UTF_8), FailoverContext[].class);
     }