Uses of Class
org.springframework.integration.kafka.dsl.KafkaInboundChannelAdapterSpec

Packages that use KafkaInboundChannelAdapterSpec

Package	Description
org.springframework.integration.kafka.dsl	Provides Spring Integration Java DSL Components support for Apache Kafka.

Uses of KafkaInboundChannelAdapterSpec in org.springframework.integration.kafka.dsl

Methods in org.springframework.integration.kafka.dsl that return KafkaInboundChannelAdapterSpec

Modifier and Type	Method	Description
static <K, V> KafkaInboundChannelAdapterSpec<K,V>	Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties)	Create an initial KafkaInboundChannelAdapterSpec with the consumer factory and topics.
static <K, V> KafkaInboundChannelAdapterSpec<K,V>	Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, boolean allowMultiFetch)	Create an initial KafkaInboundChannelAdapterSpec with the consumer factory and topics.
static <K, V> KafkaInboundChannelAdapterSpec<K,V>	Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory)	Create an initial KafkaInboundChannelAdapterSpec with the consumer factory and topics with a custom ack callback factory.
static <K, V> KafkaInboundChannelAdapterSpec<K,V>	Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K,V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K,V> ackCallbackFactory, boolean allowMultiFetch)	Create an initial KafkaInboundChannelAdapterSpec with the consumer factory and topics with a custom ack callback factory.
KafkaInboundChannelAdapterSpec<K,V>	KafkaInboundChannelAdapterSpec.messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)	Set the message converter to replace the default.
KafkaInboundChannelAdapterSpec<K,V>	KafkaInboundChannelAdapterSpec.payloadType(Class<?> type)	Set the payload type.
KafkaInboundChannelAdapterSpec<K,V>	KafkaInboundChannelAdapterSpec.rawMessageHeader(boolean rawMessageHeader)	Set to true to include the raw ConsumerRecord as headers with keys KafkaHeaders.RAW_DATA and IntegrationMessageHeaderAccessor.SOURCE_DATA.