29 questions
0
votes
2
answers
477
views
I want to know when spring-data-redis supports commands like hexpire
To use ttl for hashkey field, I want to use hexpire, the command applied to the latest redis, but I wonder if there is a reflection plan in spring-data-redis.
I used redisson before, but I support ...
- 9
3
votes
2
answers
484
views
How to avoid CheckpointOpenResourceException for Spring Boot application with Netty Server and Client
I'm experimenting with Coordinated Restore at Checkpoint (CRac) and an Spring Boot application (version 3.2.2) with Spring WebFlux containing a reactive web client (all Netty) using Azul 21.0.2.
When ...
- 31
3
votes
0
answers
140
views
Error While implementing Reactive Redis in the part of Deserialization
Could not read JSON: Cannot construct instance of reactor.core.publisher.MonoCacheTime (no Creators, like default constructor, exist): cannot deserialize from Object value (no delegate- or property-...
- 31
0
votes
1
answer
632
views
Does Lettuce work synchronously by default? (Spring Data Redis)
Lettuce github: https://github.com/lettuce-io/lettuce-core/issues/1085
1 “Spring Data Redis uses Lettuce’s synchronous and reactive API.” it says
Does that mean it works basically synchronously?
I ...
- 31
1
vote
0
answers
173
views
Is Spring Data Redis Reactive capable of pipelining
I've seen previous unanswered questions and I still don't know whether it's possible. Spring Data Redis (non-reactive) has executePipelined but is there a reactive equivalent? Specifically, are ...
- 607
0
votes
2
answers
786
views
ReactiveRedisOperations not saving object in Redis
I am using ReactiveRedisOperations to save data objects in Redis and this call returns a Mono as per the api.
I notice that if I don't do anything with this Mono return than this code does not do ...
- 619
2
votes
1
answer
769
views
Redis Pipeline using spring data redis reactive
Pipeline support is available on RedisTemplate (RedisTemplate.executePipelined) But I couldn't find any equivalent option in ReactiveRedisTemplate to use pipeline or batch operations.
Kindly direct me ...
- 195
0
votes
2
answers
3k
views
How to create Empty redis stream?
Is possible to create empty stream using spring redis data?
Am trying to create rest endpoint to create just stream without data.
Thanks,
- 665
0
votes
1
answer
1k
views
Chaining reactive calls to redis in Spring
I am trying to get all keys, and then fetch all their values using a ReactiveRedisTemplate in Spring Data Redis
(I know that scan is preferable, but I want to keep it simple for now, unless that is my ...
- 1,615
1
vote
0
answers
735
views
ReactiveRedisTemplate List Operations - set Expire and TTL
This integration test uses ReactiveRedisTemplate list operations to:
push a List to the cache using the ReactiveRedisTemplate
list operation leftPushAll()
retrieves the List as a flux from the
cache ...
- 2,366
1
vote
1
answer
2k
views
Spring Data Redis Reactive: StreamReceiver to coroutines Flow
I'm writing an app that works with Redis Stream using Spring Data Redis. I'm using spring-data-redis with Lettuce. I can successfully write to the stream as I can validate it directly in Redis via ...
- 1,612
0
votes
0
answers
437
views
Redis Stream Producer Delivery Order
I have redis stream producer and i have question about the order of records that producer sends to redis.
Redis clients use TCP to execute commands. https://redis.io/topics/protocol#networking-layer
...
- 972
0
votes
1
answer
762
views
ReactiveRedisTemplate Cache Miss
How do we handle cache miss scenario using ReactiveRedisTemplate<String, String>? Also, need to log and treat any error from underlying Redis cache as cache miss.
please suggest.
- 173
0
votes
1
answer
1k
views
Can retrieve values manually set in redis-cli but unable to set new keys through Redis Reactive in Spring Boot
I'm using Spring Webflux + Reactive Redis, my goal is to use Redis as a file cache.
I was trying to set a key with a ~100MB ByteBuffer at first, didn't work. I double-checked with the debugger to make ...
- 3
2
votes
1
answer
2k
views
Spring actuator error out the heath check during the startup : RedisReactiveHealthIndicator : Redis health check failed
We are seeing the below error after the spring boot upgrade to 2.2.11.RELEASE. I think the first health check if failing with the below error but when I invoke the health endpoint i see that health ...
- 21
2
votes
0
answers
1k
views
Correct way to store list of objects in Spring Data Redis Reactive
I need to store a list of object in Redis. Every element of the list should be accessed for a unique key. For that I think that the list of object should be stored as a map of object in Redis (I ...
- 781
2
votes
0
answers
438
views
Spring WebSession Redis Exception
I want to store my WebSession in Redis. There is no problem at put operation, but it throws exception when retrieving stored record. Here is my example stack trace
Caused by:
com.fasterxml.jackson....
- 972
0
votes
1
answer
631
views
add module "spring integration redis" which print out "XXX is not eligible for getting processed by all BeanPostProcessors [closed]
I am integrating the spring integration-redis module so as to use the RedisLockRegistry. but I got the following logs on spring boot start up.
19: 2020/09/11 21:02:25,006 2312 [INFO] [main] [...
- 39
7
votes
4
answers
4k
views
How to continuosly listen on redis stream using lettuce java library
I am trying to listen on a redis stream and process the message as and when they arrive. I am using async command and I expect the message to be pushed instead of being pulled. So I don't think a ...
- 1,444
0
votes
1
answer
1k
views
spring data redis reactive read LocaldateTime cast error
I use spring Data Redis Reactive framework and spring Boot version is 2.3.0.
Here is my Redis configuration:
@Bean("reactiveRedisTemplate")
public ReactiveRedisTemplate<String, Object&...
- 75
-1
votes
1
answer
1k
views
Is XClaim / claim supported in redis spring data - ReactiveRedisOperations.opsForStream()
To build a reliable message queue using redis streams, i am using spring-boot-starter-data-redis-reactive and lettuce dependency to process the messages from redis stream. Though i am able to add, ...
- 297
0
votes
1
answer
2k
views
What is the correct way to chain redis operations in spring-data-redis-reactive?
In spring-data-redis-reactive, writing operations returns redis execution result which makes chaining operators really hard. Take the example reddit in Chapter 1 of Redis In Action. I try to re-...
- 551
6
votes
5
answers
117k
views
Unable to connect to Redis; nested exception is io.lettuce.core.RedisConnectionException using ReactiveRedisTemplate
I am new to Reactive Programming. i need to connect to Redis to save and get some data. The redis instance is present in cloud.
Am using Lettuce Connection factory to establish the connection.
when ...
0
votes
1
answer
2k
views
async support missing in reactive redis connection
I am learning to use spring webflux and as part of it i developed an application which uses Redis to save and retrieve data. But the problem i face is when the request tries to connect to redis i get ...
1
vote
1
answer
3k
views
Spring Data Reactive Hash Redis Template for Custom Objects
I've been triyng to use the Jackson2JsonRedisSerializer to serialize a custom instance as the hash value in a Redis store. It seems that even though I have correctly created the template, no hash is ...
- 49
4
votes
0
answers
1k
views
Spring data redis stream receiver completes prematurely
I am using Spring data Redis to consume from a Redis stream ,using the reactive stream receiver to listen over a consumer group works ,but have observed that the Flux stream closes prematurely ...
- 1,324
1
vote
2
answers
4k
views
Is there a way to set a timeout in Java with Redis reactive?
I'm using ReactiveRedisConnection to configure a connection to a local redis container.
But in the future the application will be hosted on a webserver and the redis on a different server.
Is there ...
- 411
2
votes
1
answer
717
views
Strange behavior with SSE endpoint using Redis
I need to push some data to the client if it is in Redis, but client keeps reconnecting to the SSE endpoint every 5 seconds.
The backend code:
@RestController
@RequestMapping("/reactive-task")
...
- 25
4
votes
2
answers
5k
views
Usage of elapsed() function work on Mono?
I am trying to get execution time for reading from redis in reactive programming, on looking up docs I am able to see that elapsed() method will does the same and implemented code as below.
Flux....
- 707