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.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

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

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

A B D G H I K O P S