ResetConsumers feature uses slow redis command

[mcweba]

The feature to reset the consumers uses the KEYS command of redis. This command should not be used in productive environments because it may ruin performance when it's executed against large databases. See corresponding Documentation

See code below:

private void resetConsumers() {
    log.debug("RedisQues Resetting consumers");
    String keysPattern = redisPrefix + consumersPrefix + "*";
    if (log.isTraceEnabled()) {
        log.trace("RedisQues reset consumers keys: " + keysPattern);
    }
    redisClient.keys(keysPattern, keysResult -> {
        if(keysResult.failed()) {
            log.error("Unable to get redis keys of consumers");
            return;
        }
        List keys = keysResult.result().getList();
        if(keys == null || keys.size() < 1) {
            log.debug("No consumers found to reset");
            return;
        }
        redisClient.delMany(keys, delManyResult -> {
            if (delManyResult.succeeded()) {
                Long count = delManyResult.result();
                log.debug("Successfully reset " + count + " consumers");
            } else {
                log.error("Unable to delete redis keys of consumers");
            }
        });
    });
}

As an alternative to the KEYS command the SCAN command should be used.