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

Subclasses with type arguments of type KafkaInboundChannelAdapterSpec in org.springframework.integration.kafka.dsl

Modifier and Type	Class	Description
class	KafkaInboundChannelAdapterSpec<K,V>	Spec for a polled Apache Kafka inbound channel adapter.

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.