dapr / dapr/components-contrib
Support to set the last delivered entry for Redis Stream Pubsub
- Dominant language
- Go
- Stars
- 602
- Forks
- 580
- Avg merge
- 4d 9h
- Merged PRs (30d)
- 6
Description
## Describe the feature
Currently redis stream pubsub use "0" as the last delivered entry ID in the stream, here is the related [code](https://github.com/dapr/components-contrib/blob/79adc565c17ad8936048896591cd205a6609ad67/pubsub/redis/redis.go#L113). So this means it hardcode the consumer MUST receive messages in the specified stream from the very first message.
There are some sceneries that the consumer want to specify the ID of the last entry in the stream to start to sync from, for example to set the `$` but not 0 for the ID to ask sync from the last ID of the entry in the stream.
The request is to add one more config parameter in the component of type `pubsub.redis` to allow the human to setup the ID of the last entry in the stream to sync from.
## Release Note
ADD one more parameter in the pubsub.redis config to support setup the ID of the last entry in the stream.
RELEASE NOTE:
Contributor guide
Assessment
This issue has not been assessed yet.