public static class KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec extends KafkaMessageDrivenChannelAdapterSpec<KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec> implements ComponentsRegistration
KafkaMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec
extension.KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec, KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpecid, 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, useMessageBuilderFactoryautoStartup, doGet, errorChannel, id, outputChannel, phase_this, get, getIdpublic 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