public static class KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec extends KafkaMessageDrivenChannelAdapterSpec<KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec> implements ComponentsRegistration
KafkaMessageListenerContainer
configuration KafkaMessageDrivenChannelAdapterSpec
extension.KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec, KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec |
configureListenerContainer(Consumer<KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec> configurer)
Configure a listener container by invoking the
Consumer callback, with a
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec argument. |
java.util.Collection<java.lang.Object> |
getComponentsToRegister() |
autoCommitOffset, generateMessageId, generateTimestamp, keyDecoder, payloadDecoder, useMessageBuilderFactory
autoStartup, doGet, errorChannel, id, outputChannel, phase
_this, get, getId
public KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec configureListenerContainer(Consumer<KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec> configurer)
Consumer
callback, with a
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec
argument.configurer
- the configurer Java 8 Lambda.public java.util.Collection<java.lang.Object> getComponentsToRegister()
getComponentsToRegister
in interface ComponentsRegistration