[BEAM-13159] Support for Redis 5.0 streams (XADD/XREAD/XRANGE) in RedisIO

• Type: New Feature
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.36.0
• Component/s: io-java-redis
• Assignee: N. M.
• Reporter: N. M.
• Created: 01/Nov/21 16:32
• Updated: 10/Feb/22 18:25
• Resolved: 14/Dec/21 13:43

Description

Redis 5.0 and later support an append-only log data structure called a "stream" – each element has a unique incrementing ID and contains one or more string:string key-value pairs.

This seems like a gimme for a stream processing platform to support, and in fact Jedis already has support for XADD/XREAD/XRANGE in it, but the current redisIO Read and Write classes only support pcollections of single KVs and thus will need some additional work to support streams.

Issue Links

• links to: GitHub Pull Request #15858
• links to: GitHub Pull Request #16798