A B C D E F G H I K L M O P Q R S T U Z

A

AbstractConfiguration - Class in org.springframework.integration.kafka.core

Default implementation of a Configuration, storing the default topic and partitions explicitly.

AbstractConfiguration() - Constructor for class org.springframework.integration.kafka.core.AbstractConfiguration

AbstractDecodingMessageListener<K,P> - Class in org.springframework.integration.kafka.listener

Base MessageListener implementation that decodes the key and the payload using the supplied Decoders.

AbstractDecodingMessageListener(Decoder<K>, Decoder<P>) - Constructor for class org.springframework.integration.kafka.listener.AbstractDecodingMessageListener

addMessageAndMetadata(MessageAndMetadata<K, V>) - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker

afterPropertiesSet() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration

afterPropertiesSet() - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

afterPropertiesSet() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

afterPropertiesSet() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

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

AUTO_COMMIT_ENABLE - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

AUTO_COMMIT_INTERVAL - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

AUTO_OFFSET_RESET - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

autoStartup - Variable in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

AvroDatumSupport<T> - Class in org.springframework.integration.kafka.serializer.avro

AvroDatumSupport() - Constructor for class org.springframework.integration.kafka.serializer.avro.AvroDatumSupport

AvroReflectDatumBackedKafkaDecoder<T> - Class in org.springframework.integration.kafka.serializer.avro

AvroReflectDatumBackedKafkaDecoder(Class<T>) - Constructor for class org.springframework.integration.kafka.serializer.avro.AvroReflectDatumBackedKafkaDecoder

AvroReflectDatumBackedKafkaEncoder<T> - Class in org.springframework.integration.kafka.serializer.avro

AvroReflectDatumBackedKafkaEncoder(Class<T>) - Constructor for class org.springframework.integration.kafka.serializer.avro.AvroReflectDatumBackedKafkaEncoder

AvroSerializer<T> - Class in org.springframework.integration.kafka.serializer.avro

AvroSerializer() - Constructor for class org.springframework.integration.kafka.serializer.avro.AvroSerializer

AvroSpecificDatumBackedKafkaDecoder<T> - Class in org.springframework.integration.kafka.serializer.avro

AvroSpecificDatumBackedKafkaDecoder(Class<T>) - Constructor for class org.springframework.integration.kafka.serializer.avro.AvroSpecificDatumBackedKafkaDecoder

AvroSpecificDatumBackedKafkaEncoder<T> - Class in org.springframework.integration.kafka.serializer.avro

AvroSpecificDatumBackedKafkaEncoder(Class<T>) - Constructor for class org.springframework.integration.kafka.serializer.avro.AvroSpecificDatumBackedKafkaEncoder

B

BACKOFF_INCREMENT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

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

BrokerAddress - Class in org.springframework.integration.kafka.core

Encapsulates the address of a Kafka broker.

BrokerAddress(String, int) - Constructor for class org.springframework.integration.kafka.core.BrokerAddress

BrokerAddress(String) - Constructor for class org.springframework.integration.kafka.core.BrokerAddress

BrokerAddressListConfiguration - Class in org.springframework.integration.kafka.core

Kafka Configuration where the seed brokers are set up explicitly.

BrokerAddressListConfiguration(List<BrokerAddress>) - Constructor for class org.springframework.integration.kafka.core.BrokerAddressListConfiguration

brokerToBrokerAddressFunction - Static variable in class org.springframework.integration.kafka.core.ZookeeperConfiguration

C

clearMessagesLeftOver() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker

close() - Method in interface org.springframework.integration.kafka.core.Connection

Closes the connection to the broker.

close() - Method in class org.springframework.integration.kafka.core.DefaultConnection

close() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

commitOffsetsForConsumer(String, Map<Partition, Long>) - Method in interface org.springframework.integration.kafka.core.Connection

Update offsets in the native Kafka offset management system.

commitOffsetsForConsumer(String, Map<Partition, Long>) - Method in class org.springframework.integration.kafka.core.DefaultConnection

Configuration - Interface in org.springframework.integration.kafka.core

Used to configure a DefaultConnectionFactory.

connect(BrokerAddress) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory

Create a connection to a Kafka broker, caching it internally

connect(BrokerAddress) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

Connection - Interface in org.springframework.integration.kafka.core

A connection to a Kafka broker.

ConnectionFactory - Interface in org.springframework.integration.kafka.core

Creates Kafka connections and retrieves metadata for topics and partitions.

CONSUMER_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

ConsumerConfigFactoryBean<K,V> - Class in org.springframework.integration.kafka.support

ConsumerConfigFactoryBean(ConsumerMetadata<K, V>, ZookeeperConnect, Properties) - Constructor for class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean

ConsumerConfigFactoryBean(ConsumerMetadata<K, V>, ZookeeperConnect) - Constructor for class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean

ConsumerConfiguration<K,V> - Class in org.springframework.integration.kafka.support

ConsumerConfiguration(ConsumerMetadata<K, V>, ConsumerConnectionProvider, MessageLeftOverTracker<K, V>) - Constructor for class org.springframework.integration.kafka.support.ConsumerConfiguration

ConsumerConnectionProvider - Class in org.springframework.integration.kafka.support

ConsumerConnectionProvider(ConsumerConfig) - Constructor for class org.springframework.integration.kafka.support.ConsumerConnectionProvider

ConsumerException - Exception in org.springframework.integration.kafka.core

Wraps exceptions thrown by SimpleConsumer calls.

ConsumerException(Throwable) - Constructor for exception org.springframework.integration.kafka.core.ConsumerException

ConsumerException(String) - Constructor for exception org.springframework.integration.kafka.core.ConsumerException

ConsumerMetadata<K,V> - Class in org.springframework.integration.kafka.support

ConsumerMetadata() - Constructor for class org.springframework.integration.kafka.support.ConsumerMetadata

createMessageStreamsForTopic() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

createMessageStreamsForTopicFilter() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

D

decodeKey(KafkaMessage, Decoder<T>) - Static method in class org.springframework.integration.kafka.util.MessageUtils

decodePayload(KafkaMessage, Decoder<T>) - Static method in class org.springframework.integration.kafka.util.MessageUtils

DEFAULT_OFFSET_RESET - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

DEFAULT_PORT - Static variable in class org.springframework.integration.kafka.core.BrokerAddress

DefaultConnection - Class in org.springframework.integration.kafka.core

A connection to a Kafka broker.

DefaultConnection(BrokerAddress, String, int, int, int, int) - Constructor for class org.springframework.integration.kafka.core.DefaultConnection

DefaultConnectionFactory - Class in org.springframework.integration.kafka.core

Default implementation of ConnectionFactory

DefaultConnectionFactory(Configuration) - Constructor for class org.springframework.integration.kafka.core.DefaultConnectionFactory

deserialize(byte[], DatumReader<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSerializer

destroy() - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

destroy() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

doGetBrokerAddresses() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration

doGetBrokerAddresses() - Method in class org.springframework.integration.kafka.core.BrokerAddressListConfiguration

doGetBrokerAddresses() - Method in class org.springframework.integration.kafka.core.ZookeeperConfiguration

doOnMessage(K, P, KafkaMessageMetadata) - Method in class org.springframework.integration.kafka.listener.AbstractDecodingMessageListener

Process the decoded message

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

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

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

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

doStart() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

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

doStop() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

E

equals(Object) - Method in class org.springframework.integration.kafka.core.BrokerAddress

equals(Object) - Method in class org.springframework.integration.kafka.core.Partition

equals(Object) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration

equals(Object) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

ErrorHandler - Interface in org.springframework.integration.kafka.listener

Handles errors thrown during the execution of a MessageListener

F

fetch(FetchRequest...) - Method in interface org.springframework.integration.kafka.core.Connection

Fetch data from a Kafka broker.

fetch(FetchRequest...) - Method in class org.springframework.integration.kafka.core.DefaultConnection

Fetche data from Kafka.

FETCH_METADATA_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

FETCH_SIZE - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

FETCH_SIZE_INT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

fetchInitialOffset(long, Partition...) - Method in interface org.springframework.integration.kafka.core.Connection

Fetch an actual offset in the partition, immediately before the given reference time, or the smallest and largest value, respectively, if the special values -1 (OffsetRequest.LatestTime()) and -2 (OffsetRequest.LatestTime()) are used .

fetchInitialOffset(long, Partition...) - Method in class org.springframework.integration.kafka.core.DefaultConnection

FetchRequest - Class in org.springframework.integration.kafka.core

Encapsulates a request for fetching messages from the server.

FetchRequest(Partition, long, int) - Constructor for class org.springframework.integration.kafka.core.FetchRequest

fetchStoredOffsetsForConsumer(String, Partition...) - Method in interface org.springframework.integration.kafka.core.Connection

Fetch offsets from the native Kafka offset management system.

fetchStoredOffsetsForConsumer(String, Partition...) - Method in class org.springframework.integration.kafka.core.DefaultConnection

findLeaders(String...) - Method in interface org.springframework.integration.kafka.core.Connection

Retrieve the leader broker addresses for all the partitions in the given topics.

findLeaders(String...) - Method in class org.springframework.integration.kafka.core.DefaultConnection

flush() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

fromAddress(String) - Static method in class org.springframework.integration.kafka.core.BrokerAddress

fromBytes(byte[], DatumReader<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroDatumSupport

fromBytes(byte[]) - Method in class org.springframework.integration.kafka.serializer.avro.AvroReflectDatumBackedKafkaDecoder

fromBytes(byte[]) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSpecificDatumBackedKafkaDecoder

fromBytes(byte[]) - Method in class org.springframework.integration.kafka.serializer.common.StringDecoder

G

getAdminTaskExecutor() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getAutoCommitEnable() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getAutoCommitInterval() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getAutoOffsetReset() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getBackoffIncrement() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getBatchNumMessages() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.KafkaConsumerContextParser

getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.KafkaProducerContextParser

getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.ZookeeperConnectParser

getBrokerAddress() - Method in interface org.springframework.integration.kafka.core.Connection

The broker address for this consumer

getBrokerAddress() - Method in class org.springframework.integration.kafka.core.DefaultConnection

getBrokerAddresses() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration

getBrokerAddresses() - Method in interface org.springframework.integration.kafka.core.Configuration

The list of seed broker addresses used by this Configuration.

getClientId() - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

getComponentName() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

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

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

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

getComponentType() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

getCompressionCodec() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getConcurrency() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getConfiguration() - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

getConnectionFactory() - Method in class org.springframework.integration.kafka.core.KafkaTemplate

getConsumerConfiguration(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

getConsumerConfigurations() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

getConsumerConnector() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

getConsumerConnector() - Method in class org.springframework.integration.kafka.support.ConsumerConnectionProvider

getConsumerId() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

getConsumerMetadata() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

getConsumerTimeout() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getConsumerTimeout() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

getCurrentCount() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker

getDefaultPartitions() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration

getDefaultPartitions() - Method in interface org.springframework.integration.kafka.core.Configuration

A list of default partitions to perform operations on.

getDefaultTopic() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration

getDefaultTopic() - Method in interface org.springframework.integration.kafka.core.Configuration

A default topic to perform operations on.

getError(Partition) - Method in class org.springframework.integration.kafka.core.Result

getErrorHandler() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getErrors() - Method in class org.springframework.integration.kafka.core.Result

getFetchSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getFetchTaskExecutor() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getGroupId() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getHighWatermark() - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch

getHost() - Method in class org.springframework.integration.kafka.core.BrokerAddress

getId() - Method in class org.springframework.integration.kafka.core.Partition

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

getKeyClassType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getKeyDecoder() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getKeyEncoder() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getLeader(Partition) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory

Return the leader for a single partition

getLeader(Partition) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

getLeaders(Iterable<Partition>) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory

Retrieve the leaders for a set of partitions.

getLeaders(Iterable<Partition>) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

getMaxFetch() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getMaxMessages() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

getMaxSizeInBytes() - Method in class org.springframework.integration.kafka.core.FetchRequest

getMessage() - Method in class org.springframework.integration.kafka.core.KafkaMessage

getMessageLeftOverFromPreviousPoll() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker

getMessageListener() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getMessages() - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch

getMetadata() - Method in class org.springframework.integration.kafka.core.KafkaMessage

getMetadataStore() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

getNextOffset() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata

getNumberOfStreams() - Method in class org.springframework.integration.kafka.support.TopicFilterConfiguration

getObject() - Method in class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean

getObject() - Method in class org.springframework.integration.kafka.support.ProducerFactoryBean

getObjectType() - Method in class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean

getObjectType() - Method in class org.springframework.integration.kafka.support.ProducerFactoryBean

getOffset() - Method in class org.springframework.integration.kafka.core.FetchRequest

getOffset() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata

getOffset(Partition) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

getOffset(Partition) - Method in interface org.springframework.integration.kafka.listener.OffsetManager

Retrieves the offset for a given Partition

getOffsetManager() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getPartition() - Method in class org.springframework.integration.kafka.core.FetchRequest

getPartition() - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch

getPartition() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata

getPartitioner() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getPartitions(String) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory

Retrieves the partitions of a given topic

getPartitions(String) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

getPhase() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getPhase() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

getPort() - Method in class org.springframework.integration.kafka.core.BrokerAddress

getProducer() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration

getProducerConfigurations() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

getProducerMetadata() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration

getQueuedChunksMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getQueueSize() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

getRebalanceRetriesMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getReferenceTimestamp() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

getResult(Partition) - Method in class org.springframework.integration.kafka.core.Result

getResults() - Method in class org.springframework.integration.kafka.core.Result

getSocketBufferSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getSocketTimeout() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getStreams() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getTopic() - Method in class org.springframework.integration.kafka.core.Partition

getTopic() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getTopic() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getTopicConfiguration(String) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

getTopicFilter() - Method in class org.springframework.integration.kafka.support.TopicFilterConfiguration

getTopicFilterConfiguration() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getTopicStreamMap() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getValueClassType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getValueDecoder() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

getValueEncoder() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

getZkConnect() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

getZkConnectionTimeout() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

getZkSessionTimeout() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

getZkSyncTime() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

getZookeeperConnect() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

GROUP_ID - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

H

handle(Exception, KafkaMessage) - Method in interface org.springframework.integration.kafka.listener.ErrorHandler

handle(Exception, KafkaMessage) - Method in class org.springframework.integration.kafka.listener.LoggingErrorHandler

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

hashCode() - Method in class org.springframework.integration.kafka.core.BrokerAddress

hashCode() - Method in class org.springframework.integration.kafka.core.Partition

hashCode() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration

hashCode() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

I

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

isAsync() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

isAutoStartup() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

isAutoStartup() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

isEligibleAttribute(String) - Method in class org.springframework.integration.kafka.config.xml.KafkaProducerContextParser

isRunning() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

isRunning() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

isSingleton() - Method in class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean

isSingleton() - Method in class org.springframework.integration.kafka.support.ProducerFactoryBean

K

KafkaConsumerContext<K,V> - Class in org.springframework.integration.kafka.support

KafkaConsumerContext() - Constructor for class org.springframework.integration.kafka.support.KafkaConsumerContext

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

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

KafkaConsumerDefaults - Class in org.springframework.integration.kafka.core

Kafka adapter specific message headers.

KafkaConsumerDefaults() - Constructor for class org.springframework.integration.kafka.core.KafkaConsumerDefaults

KafkaHeaders - Class in org.springframework.integration.kafka.support

KafkaHeaders() - Constructor for class org.springframework.integration.kafka.support.KafkaHeaders

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

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

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

The Kafka Inbound Channel adapter parser

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

KafkaMessage - Class in org.springframework.integration.kafka.core

Wrapper around a kafka message and its metadata.

KafkaMessage(Message, KafkaMessageMetadata) - Constructor for class org.springframework.integration.kafka.core.KafkaMessage

KafkaMessageBatch - Class in org.springframework.integration.kafka.core

A group of KafkaMessages retrieved by a fetch operation

KafkaMessageBatch(Partition, List<KafkaMessage>, long) - Constructor for class org.springframework.integration.kafka.core.KafkaMessageBatch

KafkaMessageDrivenChannelAdapter - Class in org.springframework.integration.kafka.inbound

KafkaMessageDrivenChannelAdapter(KafkaMessageListenerContainer) - Constructor for class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

KafkaMessageListenerContainer - Class in org.springframework.integration.kafka.listener

KafkaMessageListenerContainer(ConnectionFactory, Partition...) - Constructor for class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

KafkaMessageListenerContainer(ConnectionFactory, String...) - Constructor for class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

KafkaMessageListenerContainer.FetchTask - Class in org.springframework.integration.kafka.listener

Fetches data from Kafka for a group of partitions, located on the same broker.

KafkaMessageListenerContainer.FetchTask(BrokerAddress) - Constructor for class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer.FetchTask

KafkaMessageMetadata - Class in org.springframework.integration.kafka.core

Metadata for a Kafka Message.

KafkaMessageMetadata(Partition, long, long) - Constructor for class org.springframework.integration.kafka.core.KafkaMessageMetadata

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

KafkaOperations - Interface in org.springframework.integration.kafka.core

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

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

KafkaProducerContext<K,V> - Class in org.springframework.integration.kafka.support

KafkaProducerContext() - Constructor for class org.springframework.integration.kafka.support.KafkaProducerContext

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

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

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

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

KafkaTemplate - Class in org.springframework.integration.kafka.core

A template for executing high-level operations on a set of Kafka brokers.

KafkaTemplate(ConnectionFactory) - Constructor for class org.springframework.integration.kafka.core.KafkaTemplate

keyFunction - Static variable in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

L

LoggingErrorHandler - Class in org.springframework.integration.kafka.listener

LoggingErrorHandler() - Constructor for class org.springframework.integration.kafka.listener.LoggingErrorHandler

M

MAX_WAIT_TIME_IN_MS - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

MESSAGE_KEY - Static variable in class org.springframework.integration.kafka.support.KafkaHeaders

MessageLeftOverTracker<K,V> - Class in org.springframework.integration.kafka.support

MessageLeftOverTracker() - Constructor for class org.springframework.integration.kafka.support.MessageLeftOverTracker

MessageListener - Interface in org.springframework.integration.kafka.listener

Listener for handling incoming Kafka messages

MessageUtils - Class in org.springframework.integration.kafka.util

MessageUtils() - Constructor for class org.springframework.integration.kafka.util.MessageUtils

MetadataStoreOffsetManager - Class in org.springframework.integration.kafka.listener

An OffsetManager that persists offsets into a MetadataStore.

MetadataStoreOffsetManager(ConnectionFactory) - Constructor for class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

MetadataStoreOffsetManager(ConnectionFactory, Map<Partition, Long>) - Constructor for class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

MIN_FETCH_BYTES - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

O

OFFSET - Static variable in class org.springframework.integration.kafka.support.KafkaHeaders

OffsetManager - Interface in org.springframework.integration.kafka.listener

Stores and retrieves offsets for a Kafka consumer

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

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

onMessage(KafkaMessage) - Method in class org.springframework.integration.kafka.listener.AbstractDecodingMessageListener

onMessage(KafkaMessage) - Method in interface org.springframework.integration.kafka.listener.MessageListener

Executes when a Kafka message is received

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.core - package org.springframework.integration.kafka.core

Provides core classes of the Kafka module.

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

Provides inbound Spring Integration Kafka components.

org.springframework.integration.kafka.listener - package org.springframework.integration.kafka.listener

Provides message listener container support

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

org.springframework.integration.kafka.serializer.avro - package org.springframework.integration.kafka.serializer.avro

org.springframework.integration.kafka.serializer.common - package org.springframework.integration.kafka.serializer.common

org.springframework.integration.kafka.support - package org.springframework.integration.kafka.support

Provides various support classes used across Spring Integration Kafka Components.

org.springframework.integration.kafka.util - package org.springframework.integration.kafka.util

P

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

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

Partition - Class in org.springframework.integration.kafka.core

A reference to a Kafka partition, with both topic and partition id

Partition(String, int) - Constructor for class org.springframework.integration.kafka.core.Partition

PARTITION_ID - Static variable in class org.springframework.integration.kafka.support.KafkaHeaders

ProducerConfiguration<K,V> - Class in org.springframework.integration.kafka.support

ProducerConfiguration(ProducerMetadata<K, V>, Producer<K, V>) - Constructor for class org.springframework.integration.kafka.support.ProducerConfiguration

ProducerFactoryBean<K,V> - Class in org.springframework.integration.kafka.support

ProducerFactoryBean(ProducerMetadata<K, V>, String, Properties) - Constructor for class org.springframework.integration.kafka.support.ProducerFactoryBean

ProducerFactoryBean(ProducerMetadata<K, V>, String) - Constructor for class org.springframework.integration.kafka.support.ProducerFactoryBean

ProducerMetadata<K,V> - Class in org.springframework.integration.kafka.support

ProducerMetadata(String) - Constructor for class org.springframework.integration.kafka.support.ProducerMetadata

Q

QUEUED_CHUNKS_MAX - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

R

REBALANCE_RETRIES_MAX - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

receive(Iterable<FetchRequest>) - Method in interface org.springframework.integration.kafka.core.KafkaOperations

Receive data from the server.

receive(Iterable<FetchRequest>) - Method in class org.springframework.integration.kafka.core.KafkaTemplate

receive() - Method in class org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource

receive() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

receive() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

refreshLeaders(Collection<String>) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory

Refresh the broker connections and partition leader map.

refreshLeaders(Collection<String>) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

resetOffsets(Collection<Partition>) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

resetOffsets(Collection<Partition>) - Method in interface org.springframework.integration.kafka.listener.OffsetManager

Resets offsets for the given Partitions.

Result<T> - Class in org.springframework.integration.kafka.core

The result of a Kafka SimpleConsumer operation

run() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer.FetchTask

S

send(String, Object, Message<?>) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

send(String, Object, Message<?>) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration

serialize(T, DatumWriter<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSerializer

setAdminTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

setAsync(boolean) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setAutoCommitEnable(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setAutoCommitInterval(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setAutoOffsetReset(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

setBackoffIncrement(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setBatchNumMessages(String) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setBeanName(String) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

setBufferSize(int) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

The buffer size for this client

setClientId(String) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

A client name to be used throughout this connection.

setCompressionCodec(String) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setConcurrency(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

The maximum number of concurrent MessageListeners running.

setConsumerConfigurations(Map<String, ConsumerConfiguration<K, V>>) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

setConsumerId(String) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

The identifier of a consumer of Kafka messages.

setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

setDefaultPartitions(List<Partition>) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration

setDefaultTopic(String) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration

setEncoding(String) - Method in class org.springframework.integration.kafka.serializer.common.StringEncoder

setErrorHandler(ErrorHandler) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

setExecutor(Executor) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

setFetchMetadataTimeout(int) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

The timeout on fetching metadata (e.g.

setFetchSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setFetchTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

The task executor for fetch operations

setGroupId(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setHighWatermark(long) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch

setId(int) - Method in class org.springframework.integration.kafka.core.Partition

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

setKeyClassType(Class<K>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setKeyDecoder(Decoder<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

setKeyDecoder(Decoder<K>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setKeyEncoder(Encoder<K>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setMaxFetch(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

setMaxMessages(int) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

setMaxSizeInBytes(int) - Method in class org.springframework.integration.kafka.core.FetchRequest

setMaxWait(int) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

The maximum amount of time that a server fetch operation will wait before returning (unless minFetchSizeInBytes) are available.

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

setMessageListener(MessageListener) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

setMessages(List<KafkaMessage>) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch

setMetadataStore(MetadataStore) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

The backing MetadataStore for storing offsets.

setMinBytes(int) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

The minimum amount of data that a server fetch operation will wait for before returning, unless maxWaitTimeInMs has elapsed.

setOffset(long) - Method in class org.springframework.integration.kafka.core.FetchRequest

setOffsetManager(OffsetManager) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

setPartition(Partition) - Method in class org.springframework.integration.kafka.core.FetchRequest

setPartition(Partition) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch

setPartitioner(Partitioner) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setPayloadDecoder(Decoder<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter

setPhase(int) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

setProducerConfigurations(Map<String, ProducerConfiguration<K, V>>) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

setQueuedChunksMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setQueueSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

The maximum number of messages that are buffered by each concurrent MessageListener runner.

setRebalanceRetriesMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setReferenceTimestamp(long) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

A timestamp to be used for resetting initial offsets, if they are not available in the MetadataStore

setSocketBufferSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setSocketTimeout(int) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory

The socket timeout for this client

setSocketTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setStreams(int) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setTopic(String) - Method in class org.springframework.integration.kafka.core.Partition

setTopic(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

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

setTopicFilterConfiguration(TopicFilterConfiguration) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setTopicStreamMap(Map<String, Integer>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setValueClassType(Class<V>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setValueDecoder(Decoder<V>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata

setValueEncoder(Encoder<V>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata

setZkConnect(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

setZkConnectionTimeout(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

setZkSessionTimeout(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

setZkSyncTime(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect

setZookeeperConnect(ZookeeperConnect) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext

shutdown() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration

SOCKET_BUFFER_SIZE - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

SOCKET_BUFFER_SIZE_INT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

SOCKET_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

SOCKET_TIMEOUT_INT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults

start() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

start() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

stop(Runnable) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

stop() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer

stop() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

stop(Runnable) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext

stop() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration

StringDecoder - Class in org.springframework.integration.kafka.serializer.common

String Decoder for Kafka message key/value decoding.

StringDecoder() - Constructor for class org.springframework.integration.kafka.serializer.common.StringDecoder

StringDecoder(String) - Constructor for class org.springframework.integration.kafka.serializer.common.StringDecoder

StringEncoder<T> - Class in org.springframework.integration.kafka.serializer.common

StringEncoder() - Constructor for class org.springframework.integration.kafka.serializer.common.StringEncoder

T

toBytes(T, DatumWriter<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroDatumSupport

toBytes(T) - Method in class org.springframework.integration.kafka.serializer.avro.AvroReflectDatumBackedKafkaEncoder

toBytes(T) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSpecificDatumBackedKafkaEncoder

toBytes(Object) - Method in class org.springframework.integration.kafka.serializer.common.StringEncoder

TOPIC - Static variable in class org.springframework.integration.kafka.support.KafkaHeaders

TopicFilterConfiguration - Class in org.springframework.integration.kafka.support

TopicFilterConfiguration(String, int, boolean) - Constructor for class org.springframework.integration.kafka.support.TopicFilterConfiguration

TopicNotFoundException - Exception in org.springframework.integration.kafka.core

TopicNotFoundException(String) - Constructor for exception org.springframework.integration.kafka.core.TopicNotFoundException

toString() - Method in class org.springframework.integration.kafka.core.BrokerAddress

toString() - Method in class org.springframework.integration.kafka.core.KafkaMessage

toString() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata

toString() - Method in class org.springframework.integration.kafka.core.Partition

toString() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration

toString() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

toString() - Method in class org.springframework.integration.kafka.support.TopicFilterConfiguration

U

updateOffset(Partition, long) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

updateOffset(Partition, long) - Method in interface org.springframework.integration.kafka.listener.OffsetManager

Updates the offset for a given Partition

Z

ZK_CONNECT - Static variable in class org.springframework.integration.kafka.core.ZookeeperConnectDefaults

ZK_CONNECTION_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.ZookeeperConnectDefaults

ZK_SESSION_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.ZookeeperConnectDefaults

ZK_SYNC_TIME - Static variable in class org.springframework.integration.kafka.core.ZookeeperConnectDefaults

ZookeeperConfiguration - Class in org.springframework.integration.kafka.core

Kafka Configuration that uses a ZooKeeper connection for retrieving the list of seed brokers.

ZookeeperConfiguration(ZookeeperConnect) - Constructor for class org.springframework.integration.kafka.core.ZookeeperConfiguration

ZookeeperConnect - Class in org.springframework.integration.kafka.support

ZookeeperConnect() - Constructor for class org.springframework.integration.kafka.support.ZookeeperConnect

ZookeeperConnectDefaults - Class in org.springframework.integration.kafka.core

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

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

A B C D E F G H I K L M O P Q R S T U Z