Skip navigation links
Spring Integration Kafka Support
A B D G H I K O P R S T V 

A

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

B

beforeShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
 
buildErrorMessage(Throwable, AttributeAccessor) - Method in class org.springframework.integration.kafka.support.RawRecordHeaderErrorMessageStrategy
 

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
 
getErrorMessageAttributes(Message<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
 
getKafkaTemplate() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
 
getRecord() - Method in exception org.springframework.integration.kafka.support.KafkaSendFailureException
 
getSendFailureChannel() - 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

KAFKA_RAW_DATA - Static variable in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Header name/retry context variable for the raw received record (or records).
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
KafkaMessageDrivenChannelAdapter(AbstractMessageListenerContainer<K, V>, KafkaMessageDrivenChannelAdapter.ListenerMode) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Construct an instance with the provided mode.
KafkaMessageDrivenChannelAdapter.ListenerMode - Enum in org.springframework.integration.kafka.inbound
The listener mode for the container, record or batch.
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
 
KafkaSendFailureException - Exception in org.springframework.integration.kafka.support
An exception that is the payload of an ErrorMessage when a send fails.
KafkaSendFailureException(Message<?>, ProducerRecord<?, ?>, Throwable) - Constructor for exception org.springframework.integration.kafka.support.KafkaSendFailureException
 

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
Provides outbound Spring Integration Kafka components.
org.springframework.integration.kafka.support - package org.springframework.integration.kafka.support
Provides support classes.

P

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

R

RawRecordHeaderErrorMessageStrategy - Class in org.springframework.integration.kafka.support
ErrorMessageStrategy extension that adds the raw record as a header to the EnhancedErrorMessage.
RawRecordHeaderErrorMessageStrategy() - Constructor for class org.springframework.integration.kafka.support.RawRecordHeaderErrorMessageStrategy
 

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.
setBatchMessageConverter(BatchMessageConverter) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Set the message converter to use with a batch-based consumer.
setErrorMessageStrategy(ErrorMessageStrategy) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
Set the error message strategy implementation to use when sending error messages after send failures.
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.
setHeaderMapper(KafkaHeaderMapper) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
Set the header mapper to use.
setMessageConverter(MessageConverter) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Set the message converter; must be a RecordMessageConverter or BatchMessageConverter depending on mode.
setMessageKeyExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
 
setPartitionIdExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
 
setPayloadType(Class<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
When using a type-aware message converter (such as StringJsonMessageConverter, set the payload type the converter should create.
setRecordFilterStrategy(RecordFilterStrategy<K, V>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Specify a RecordFilterStrategy to wrap KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener into FilteringAcknowledgingMessageListenerAdapter.
setRecordMessageConverter(RecordMessageConverter) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Set the message converter to use with a record-based consumer.
setRecoveryCallback(RecoveryCallback<? extends Object>) - 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 (unless an error channel is configured).
setRetryTemplate(RetryTemplate) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Specify a RetryTemplate instance to wrap KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener into RetryingAcknowledgingMessageListenerAdapter.
setSendFailureChannel(MessageChannel) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
Set the failure channel.
setSendFailureChannelName(String) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
Set the failure channel name.
setSendTimeout(long) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
Specify a timeout in milliseconds for how long this KafkaProducerMessageHandler should wait wait for send operation results.
setSendTimeoutExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
Specify a SpEL expression to evaluate a timeout in milliseconds for how long this KafkaProducerMessageHandler should wait wait for send operation results.
setSync(boolean) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
A boolean indicating if the KafkaProducerMessageHandler should wait for the send operation results or not.
setTimestampExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
Specify a SpEL expression to evaluate a timestamp that will be added in the Kafka record.
setTopicExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
 

T

toString() - Method in exception org.springframework.integration.kafka.support.KafkaSendFailureException
 

V

valueOf(String) - Static method in enum org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.ListenerMode
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.ListenerMode
Returns an array containing the constants of this enum type, in the order they are declared.
A B D G H I K O P R S T V 
Skip navigation links
Spring Integration Kafka Support