92 questions
1
vote
1
answer
73
views
Redis Streams uneven distribution of messages across the PEL's of multiple pods in Kubernetes environment
I'm currently running a StreamMessageListenerContainer in a Springboot application, and deployed it to Kubernetes. There's 4-6 pods in Kubernetes, but I made sure that each pod has a unique consumer ...
0
votes
1
answer
77
views
Managing of consumers in Redis Streams
I will autoscale consumers using k8s KEDA based on new items in Redis Streams.
I wonder how to manage consumers in Redis. Is there a way to delete them automatically if no items are pending, or do I ...
- 26.8k
-2
votes
2
answers
604
views
Enable redis stream in redis helm chart bitnami with terraform
I am trying to deploy a standalone redis with bitnami helm chart and activate the redis stream and set the stream-db-max-len to 100. I have this tf file:
resource "helm_release" "redis&...
-3
votes
2
answers
228
views
Redis Stream I need Event Driven Architecture,
When any new message received in the stream, on that time OnMessageReceived event should trigger.
public event EventHandler<MqMessageReceivedEventArgs> OnMessageReceived;
var result = await ...
- 9
0
votes
0
answers
131
views
the java send entity to redis stream convert to base64
When I tried to send object data to redis stream(Redis Version: 7.0.8) using java(java 11) like this:
package com.dolphin.soa.post.common.mq;
import com.dolphin.soa.post.model.custom.NicknameEdit;
...
- 40.8k
0
votes
1
answer
110
views
how can i put all tabels changes in one streams in debezium&redis-stream
I want to monitor one postgres database's changes with debezium-server and put all these changes into redis stream.But after my test i can only xread one table's change in one command, like xread ...
- 1
2
votes
1
answer
900
views
How to remove completed redis stream events?
Trying to remove the completed redis stream events after particular time interval. Currently, we can remove the redis stream events after particular time interval using XTRIM command , but it will ...
- 21
1
vote
1
answer
2k
views
Spring Boot Data Redis Stream consume messages in Batch
I am trying to consume messages from Redis Stream in Batch using Imperative StreamMessageListenerContainer of Spring Boot Data Redis.
But this have method signature of 'MapRecord<String, String, ...
- 77
1
vote
0
answers
597
views
Using Django Channels with Redis Streams
I have written a Django application to receive updates of long running tasks. I am using Redis as a channel layer for web-sockets and also making use of Redis Streams to store the updates of the tasks ...
1
vote
1
answer
929
views
Debezium is not working with redis streams and postgresql
I'm having an issue with running debezium with redis and postgresql.
My docker compose is:
version: "3.3"
services:
redis-stack:
image: redis/redis-stack:7.0.6-RC4
restart: unless-...
- 608
0
votes
0
answers
61
views
I want a similar data Structure as a Redis list which also have maximum limit on length as like Redis Stream
I want a similar data Structure as a Redis list which also have maximum limit on length as like Redis Stream. My usecase is to consume less space less operation(I can use stream but it is not good ...
0
votes
1
answer
266
views
Are StackExchange.Redis fire-and-forget calls guaranteed to be delivered in order?
If I make multiple StackExchange.Redis calls from a single thread using fire-and-forget, are they guaranteed to be delivered in order?
Use case: I am adding an item to a Redis stream and then using ...
- 7,701
0
votes
1
answer
1k
views
Redis streams - free struck messages in a consumer group without claiming
Lets say, there are messages in a Redis consumer group that has not been processed for N seconds. I am trying to understand if its possible to free them and put them back for other members of the ...
- 1,736
0
votes
1
answer
203
views
Make two microservices hosted on different machine communicate with each other using Redis Pub/Sub
I have two diiferent microserivice and one API Gateway. All hosted on different machine. I want both microservice communicate with each other using Redis Pub/Sub.
I am able to make them talk to each ...
- 111
3
votes
1
answer
2k
views
How do I delete an entire stream in redis?
I am new to redis streams, I have googled a lot, but I still cannot figure this question out:
How do I delete an entire stream in redis? I don't need that stream anymore, I want to delete it to ...
- 183
1
vote
2
answers
1k
views
Order of processing different Redis Streams messages
Given that I have a service P (Producer) and C (Consumer) my P service needs to:
Create an object X
Create an object Y (dependent on X)
Create an object Z (dependent on Y)
Notify C about X, Y, and Z (...
- 20.2k
2
votes
0
answers
960
views
How does spring-data-redis get an objectRecord with a Generic type
I want to implement MQ using stream in Redis, and when the entity type passed is generic, my code does not deserialize the entity consumption message correctly.
producer critical code:
@Bean
...
1
vote
1
answer
701
views
Spring Redis Does Not Delete the Stream Entries
I'm using the Redis Template and I want to delete the entries of the stream after processing it. I used the below code but it didn't delete from the Redis Streams.
redisTemplate.opsForStream().delete(&...
- 69
1
vote
1
answer
925
views
how to work with XREAD .NET Redis to read actual changes
When i am set stop point at line with XREAD programm doing nothing. Maybe i need to configure this XREAD command?
public async void ListenTask()
{
var readTask = Task.Run(async () =>...
- 77
1
vote
0
answers
2k
views
Handling PENDING messages from Redis Stream with Spring Data Redis
When using StreamMessageListenerContainer a subscription for a consumer group can be created by calling:
receive(consumer, readOffset, streamListener)
Is there a way to configure the container/...
- 18.7k
0
votes
2
answers
2k
views
How do I clear the PEL list for a consumer group in Redis
I would like to know how to clear the PEL list for a given Redis consumer group without individually acknowledging every message.
Context
I have a consumer group for my one of my Redis streams. For ...
- 151
3
votes
1
answer
3k
views
Can Redis consumer group guarantee that multi-consumers running parallelly consume different exclusive subset from the same stream?
Currently, I have a redis stream which have many entries produced. I want to process stream parallelly but make sure each entry is processed only once. I search the official document about redis ...
- 871
3
votes
1
answer
3k
views
Redis Streams Partitioning
I am trying to understand how redis streams does partitioning , if a specific message can be sent to a specific partition (similar to how you can do with Kafka).
I have checked the redis-cli api , and ...
- 9,450
1
vote
2
answers
569
views
Redis Stream NOMKSTREAM
What is this NOMKSTREAM in redis stream?
I went through the documentation. Too bad they do not even provide simple description about it.
https://redis.io/commands/xadd
Can someone please explain?
- 3,590
0
votes
1
answer
1k
views
Redis XREAD and XREVRANGE in Node.js
client.xrevrange('TEST_STREAM','count 1',function (err,Data) {
if (err) {
return console.error(err);
} else
console.log("Data from stream is:",Data);
});
I'm trying to read the ...
