ClassCastException after updating to Lettuce-6.2 mget method

[thedeveshbajpai]

Hey All,

I recently updated Lettuce module from 4.2 to 6.2, where older List<V> mget(K... keys) method return type has been updated to List<KeyValue<K, V>> mget(K... keys). To bridge the gap I modified return of mget to get List as output

List<KeyValue<ByteBuffer, byte[]>> value =
   redisAdvancedClusterCommands.mget(Arrays.stream(keys).map(ByteBuffer::wrap).toArray(ByteBuffer[]::new));
List<byte[]> valList = null;
for (KeyValue<ByteBuffer, byte[]> kv : value) { // <-- Throwing ClassCastException
   valList.add(kv.getValue());
}
return valList;
// where keys is byte[][]

However, this is leading to ClassCastException

class [B cannot be cast to class io.lettuce.core.KeyValue ([B is in module java.base of loader 'bootstrap'; io.lettuce.core.KeyValue is in unnamed module of loader 'app')

java.lang.ClassCastException: class [B cannot be cast to class io.lettuce.core.KeyValue ([B is in module java.base of loader 'bootstrap'; io.lettuce.core.KeyValue is in unnamed module of loader 'app')

The exception is coming from an unit test which is calling this method with keys:

private static final byte[] TEST_KEY = "test:key".getBytes(UTF8);
private static final Map<String, byte[]> KEYS_TO_VALUE = new LinkedHashMap<>();
KEYS_TO_VALUE.put(new String(TEST_KEY, UTF8), TEST_VALUE);
byte[][] keys = KEYS_TO_VALUE.keySet().stream().map(key -> key.getBytes(UTF8)).toArray(byte[][]::new)

Is there a way to resolve this?
I have also upgraded JDK from 8 to 17.

[tishun]

Hey @thedeveshbajpai ,

could you please let me know what type of codec you are using when you create the Redis connection?