This module provides a Cassandra Consumer that can be reused and composed in other applications.
Internally it uses the CassandraMessageHandler from Spring Integration.
CassandraConsumerFunction is implemented as a java.util.function.Function.
You can import the CassnadraConsumerConfiguration in the application and then inject the following bean.
cassandraConsumerFunction
You can use cassandraConsumerFunction as a qualifier when injecting.
Type for injection: Function<Object, Mono<? extends WriteResult>>
You can ignore the return value from the function as this is a consumer and simply will send the data to Cassandra.
All configuration properties are prefixed with either cassandra or cassandra.cluster.
For more information on the various options available, please see CassandraConsumerProperties. See this also.
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 Cassandra sink.