diff --git a/src/main/java/org/redisson/codec/KryoCodec.java b/src/main/java/org/redisson/codec/KryoCodec.java old mode 100644 new mode 100755 index 2b5d9ce0f..78afdd448 --- a/src/main/java/org/redisson/codec/KryoCodec.java +++ b/src/main/java/org/redisson/codec/KryoCodec.java @@ -18,6 +18,7 @@ package org.redisson.codec; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.nio.ByteBuffer; +import java.nio.charset.Charset; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; @@ -126,12 +127,12 @@ public class KryoCodec implements RedissonCodec { @Override public byte[] encodeKey(Object key) { - return encodeValue(key); + return key.toString().getBytes(Charset.forName("ASCII")); } @Override public Object decodeKey(ByteBuffer bytes) { - return decode(bytes); + return new String(bytes.array(), bytes.arrayOffset() + bytes.position(), bytes.limit(), Charset.forName("ASCII")); } @Override