A consumer that allows you to insert records into a relational database.
The consumer uses the JdbcMessageHandler
from Spring Integration.
You can import JdbcConsumerConfiguration
in the application and then inject the following bean.
Consumer<Message<?>> jdbcConsumer
You can use jdbcConsumer
as a qualifier when injecting.
All configuration properties are prefixed with jdbc.consumer
.
For more information on the various options available, please see JdbcConsumerProperties.
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 Jdbc sink.