K
- the key type.V
- the value type.S
- the target Kafka09MessageDrivenChannelAdapterSpec
implementation type.public class Kafka09MessageDrivenChannelAdapterSpec<K,V,S extends Kafka09MessageDrivenChannelAdapterSpec<K,V,S>> extends MessageProducerSpec<S,Kafka09MessageDrivenChannelAdapter<K,V>>
MessageProducerSpec
implementation for the Kafka09MessageDrivenChannelAdapter
.Modifier and Type | Class and Description |
---|---|
static class |
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec<K,V>
A
ConcurrentMessageListenerContainer configuration Kafka09MessageDrivenChannelAdapterSpec
extension. |
static class |
Kafka09MessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec<K,V>
A helper class in the Builder pattern style to delegate options to the
ConcurrentMessageListenerContainer . |
id, logger, PARSER, target
autoStartup, errorChannel, errorChannel, id, outputChannel, outputChannel, phase
_this, doGet, get, getId, getObject, getObjectType, isSingleton