A consumer that allows you to log the data
The consumer uses the LoggingMessageHandler from Spring Integration.
You can import LogConsumerConfiguration in the application and then inject the following bean.
Consumer<Message<?>> logConsumer
You can use logConsumer as a qualifier when injecting.
All configuration properties are prefixed with log.
For more information on the various options available, please see LogConsumerProperties.
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 Log sink.