Problem with mget() on version 6.1.5.RELEASE

[rami51]

Hi, I was trying to run an mget() on a program, stressing it with over 6000 requests per minute and after an hour, my program just stopped working and the last log that I have is:

{'level':'DEBUG', 'message': '[channel=0x83706877, /127.0.0.1:55280 -> localhost/127.0.0.1:6379] writing command SubscriptionCommand [type=MGET, output=KeyValueListOutput [output=[], error='null'], commandType=io.lettuce.core.protocol.Command]', 'loggerName': 'io.lettuce.core.protocol.CommandEncoder:101', 'timestamp': '2021-10-25 11:57:58,521', 'thread': 'lettuce-nioEventLoop-4-1'}

As you can see, I was locally running a docker container with my redis instance and connected to it by lettuce.

Originally posted by @rami51 in #1837 (comment)

[mp911de]

Without a reproducer, it is next to impossible to find out what has happened.

[rami51]

Hi, we could solve the problem by using Guava.

val ids : List<String>  // 200 elements some times
val partition = Lists.partition(ids, 20) // com.google.common.collect.Lists

val topics = partition.map { idsSublist ->
    redisConnection.mget(*idsSublist.map { forKey(it) }.toTypedArray()).toList().filter { it.hasValue() }.map { deserialize(it.value)  }
}

return ids.flatten()

Our ids list used to have 200 elements, and after an hour, it begins to making problems. We achieve to solve the problem by using this Guava alternative. So, I think, you can close the issue. Thank you @mp911de !