Support stream command XACKDEL and XDELEX
Search before asking
- [x] I had searched in the issues and found no similar issues.
Motivation
- Streams Command Upgrades: New XDELEX and XACKDEL, and Extended XADD and XTRIM. Streams, a powerful message stream processing mechanism provided by Redis, supports efficient log collection, event-driven, and message queue scenarios. The commands and extensions added in version 8.2.0 significantly enrich the stream data manipulation capabilities: • XDELEX This is a new message deletion command for Redis Streams, allowing users to delete specific messages from a stream by ID. This allows for proactive message cleanup within long-running streams, reducing memory usage and improving stream data manageability. • XACKDEL This is an enhancement to the consumer group acknowledgment (XACK) command, supporting the simultaneous deletion of acknowledged messages, addressing the limitation of traditional methods that only serve as acknowledgment markers and cannot purge data. • Extensions to XADD and XTRIM The extended XADD supports more flexible message addition methods, while XTRIM adds more powerful pruning strategies to optimize stream length control, facilitating the management of continuously growing stream data. https://mp.weixin.qq.com/s/gdW-LuYbXlIuOshj0iJcGA
Solution
No response
Are you willing to submit a PR?
- [ ] I'm willing to submit a PR!
XACKDEL: https://redis.io/docs/latest/commands/xackdel/ XDELEX: https://redis.io/docs/latest/commands/xdelex/
XACKDEL: https://redis.io/docs/latest/commands/xackdel/ XDELEX: https://redis.io/docs/latest/commands/xdelex/
Hi! I’m interested in contributing and would love to take this issue if it’s still open. Would it be okay for me to take it on?
@guozhihao-224 Assigned, thank you!
我实现了其中一个 xackdel https://github.com/apache/kvrocks/pull/3275 另外一个XDELEX 我暂时用不到,欢迎其他人认领
I've implemented one of xackdel's implementations (#3275). I don't need the other one, XDELEX, for now; others are welcome to claim it.