A consumer that allows you to write incoming messages into Redis.
You can import RedisConsumerConfiguration
in the application and then inject the following bean.
Consumer<Message<?>> redisConsumer
You can use redisConsumer
as a qualifier when injecting.
All configuration properties are prefixed with redis.consumer
.
For more information on the various options available, please see RedisConsumerProperties.
See this test suite for the various ways, this consumer is used.
See this README where this consumer is used to create a Spring Cloud Stream application where it makes a Redis sink.