support for stream data type

[shancz]

Please add support for stream data type.

Redis offers the stream data type with the following basic commands:

XADD adds a new entry to a stream.
XREAD reads one or more entries, starting at a given position and moving forward in time.
XRANGE returns a range of entries between two supplied entry IDs.
XLEN returns the length of a stream.

Having a connector that supports the steam data type would allow Flink to source and sink continuously from and to Redis.
This would allow for extremely fast real-time processing.

Please add support for stream data type. Thank you.

[jeff-zou]

OK, I can add it. By the way, what use cases can readis stream be used in? Why not use a message queue like Kafka?

[shancz]

Jeff,
Thank you for your help. Having support for Redis streams data type would allow a projects to use Redis as a message broker. For certain projects Redis streams could be used instead of Kafka therefore keeping the data and messages in one service.
Especially the consumer group concept would be super helpful.

Again most appreciate your kind and quick response.
Steven.