A B D G H I K O P S

A

afterShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

B

beforeShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

D

doParse(Element, ParserContext, String) - Method in class org.springframework.integration.kafka.config.xml.KafkaMessageDrivenChannelAdapterParser

doStart() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

doStop() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

G

getComponentType() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

getComponentType() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

getKafkaTemplate() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

H

handleMessageInternal(Message<?>) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

I

init() - Method in class org.springframework.integration.kafka.config.xml.KafkaNamespaceHandler

K

KafkaMessageDrivenChannelAdapter<K,V> - Class in org.springframework.integration.kafka.inbound

Message-driven channel adapter.

KafkaMessageDrivenChannelAdapter(AbstractMessageListenerContainer<K, V>) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

KafkaMessageDrivenChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml

Parser for the message driven channel adapter.

KafkaMessageDrivenChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaMessageDrivenChannelAdapterParser

KafkaNamespaceHandler - Class in org.springframework.integration.kafka.config.xml

The namespace handler for the Kafka namespace.

KafkaNamespaceHandler() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaNamespaceHandler

KafkaOutboundChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml

Parser for the outbound channel adapter.

KafkaOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaOutboundChannelAdapterParser

KafkaProducerMessageHandler<K,V> - Class in org.springframework.integration.kafka.outbound

Kafka Message Handler.

KafkaProducerMessageHandler(KafkaTemplate<K, V>) - Constructor for class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

O

onInit() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

onInit() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

org.springframework.integration.kafka.config.xml - package org.springframework.integration.kafka.config.xml

Provides parser classes to provide Xml namespace support for the Kafka components.

org.springframework.integration.kafka.inbound - package org.springframework.integration.kafka.inbound

Provides inbound Spring Integration Kafka components.

org.springframework.integration.kafka.outbound - package org.springframework.integration.kafka.outbound

P

parseConsumer(Element, ParserContext) - Method in class org.springframework.integration.kafka.config.xml.KafkaOutboundChannelAdapterParser

S

setAckDiscarded(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

A boolean flag to indicate if FilteringAcknowledgingMessageListenerAdapter should acknowledge discarded records or not.

setFilterInRetry(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

The boolean flag to specify the order how RetryingAcknowledgingMessageListenerAdapter and FilteringAcknowledgingMessageListenerAdapter are wrapped to each other, if both of them are present.

setMessageConverter(MessageConverter) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

setMessageKeyExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

setPartitionIdExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

setRecordFilterStrategy(RecordFilterStrategy<K, V>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

Specify a RecordFilterStrategy to wrap KafkaMessageDrivenChannelAdapter.IntegrationMessageListener into FilteringAcknowledgingMessageListenerAdapter.

setRecoveryCallback(RecoveryCallback<Void>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

A RecoveryCallback instance for retry operation; if null, the exception will be thrown to the container after retries are exhausted.

setRetryTemplate(RetryTemplate) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

Specify a RetryTemplate instance to wrap KafkaMessageDrivenChannelAdapter.IntegrationMessageListener into RetryingAcknowledgingMessageListenerAdapter.

setSendTimeout(long) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

Specify a timeout in milliseconds how long KafkaProducerMessageHandler should wait wait for send operation results.

setSync(boolean) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

The boolean indicated if KafkaProducerMessageHandler should wait for send operation results or not.

setTopicExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler

A B D G H I K O P S