I have a Flux stream that reads objects from the database. For each of these objects, I have a processing function to be run. I want the processing function to execute after acquiring Redis lock on ID of given object,…
I'm trying to established reactive connection via lettuce, connection @Bean public LettuceConnectionFactory redisConnectionFactory() { return new LettuceConnectionFactory(); } Reactive Redis Template @Bean public ReactiveRedisTemplate<String, Object> reactiveRedisTemplate(ReactiveRedisConnectionFactory connectionFactory) { KryoSerializer<String> kryoSerializer = new KryoSerializer<>(); RedisSerializationContext<String, Object> serializationContext = RedisSerializationContext.<String, Object>newSerializationContext(new StringRedisSerializer())…