K - the key type.V - the value type.S - the target KafkaMessageDrivenChannelAdapterSpec implementation type.public class KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,S>> extends MessageProducerSpec<S,org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V>>
MessageProducerSpec implementation for the KafkaMessageDrivenChannelAdapter.| Modifier and Type | Class and Description |
|---|---|
static class |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>
A
ConcurrentMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec
extension. |
static class |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V>
A helper class in the Builder pattern style to delegate options to the
ConcurrentMessageListenerContainer. |
id, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
KafkaMessageDrivenChannelAdapterSpec<K,V,S> |
batchMode(boolean batchMode) |
protected org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V> |
doGet() |
autoStartup, errorChannel, errorChannel, id, outputChannel, outputChannel, phase_this, get, getId, getObject, getObjectType, isSingletonpublic KafkaMessageDrivenChannelAdapterSpec<K,V,S> batchMode(boolean batchMode)