Index (Spring Integration Kafka Support 1.3.1.RELEASE API)

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

A

AbstractConfiguration - Class in org.springframework.integration.kafka.core: Default implementation of a Configuration, storing the default topic and partitions, as well as connectivity parameters.
AbstractConfiguration() - Constructor for class org.springframework.integration.kafka.core.AbstractConfiguration
AbstractDecodingAcknowledgingMessageListener<K,P> - Class in org.springframework.integration.kafka.listener: Base AcknowledgingMessageListener implementation that decodes the key and the payload using the supplied Decoders.
AbstractDecodingAcknowledgingMessageListener(Decoder<K>, Decoder<P>) - Constructor for class org.springframework.integration.kafka.listener.AbstractDecodingAcknowledgingMessageListener
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
AbstractOffsetManager - Class in org.springframework.integration.kafka.listener: Base implementation for OffsetManager.
AbstractOffsetManager(ConnectionFactory) - Constructor for class org.springframework.integration.kafka.listener.AbstractOffsetManager
AbstractOffsetManager(ConnectionFactory, Map<Partition, Long>) - Constructor for class org.springframework.integration.kafka.listener.AbstractOffsetManager
acknowledge() - Method in interface org.springframework.integration.kafka.listener.Acknowledgment: Invoked when the message for which the acknowledgment has been created has been processed.
acknowledge() - Method in class org.springframework.integration.kafka.listener.DefaultAcknowledgment
AcknowledgingMessageListener - Interface in org.springframework.integration.kafka.listener: Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients can invoke when the message has been processed.
Acknowledgment - Interface in org.springframework.integration.kafka.listener: Handle for acknowledging the processing of a KafkaMessage.
ACKNOWLEDGMENT - Static variable in class org.springframework.integration.kafka.support.KafkaHeaders
addListenedPartitionsIfActive(Iterable<Partition>) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer.FetchTask
addMessageAndMetadata(MessageAndMetadata<K, V>) - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker: Deprecated.
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.listener.KafkaNativeOffsetManager
afterPropertiesSet() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
afterPropertiesSet() - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager
afterPropertiesSet() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
afterShutdown() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
asCommaSeparatedHexDump(byte[]) - Static method in class org.springframework.integration.kafka.util.LoggingUtils
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
BACKOFF_INCREMENT_INT - 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
BrokerAddress(Broker) - 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(BrokerAddress...) - Constructor for class org.springframework.integration.kafka.core.BrokerAddressListConfiguration
brokerToBrokerAddressFunction - Static variable in class org.springframework.integration.kafka.core.ZookeeperConfiguration

C

CLEANUP_POLICY - Static variable in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
CLEANUP_POLICY_COMPACT - Static variable in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
clearMessagesLeftOver() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker: Deprecated.
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.KafkaNativeOffsetManager
close() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
close() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.KeySerializerDecoder
close() - Method in class org.springframework.integration.kafka.listener.LongSerializerDecoder
close() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
close() - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager
close() - Method in class org.springframework.integration.kafka.util.EncoderAdaptingSerializer
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.
configure(Map<String, ?>, boolean) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.KeySerializerDecoder
configure(Map<String, ?>, boolean) - Method in class org.springframework.integration.kafka.listener.LongSerializerDecoder
configure(Map<String, ?>, boolean) - Method in class org.springframework.integration.kafka.util.EncoderAdaptingSerializer
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.
connectionFactory - Variable in class org.springframework.integration.kafka.listener.AbstractOffsetManager
CONSUMER_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
ConsumerConfigFactoryBean<K,V> - Class in org.springframework.integration.kafka.support: Deprecated.
ConsumerConfigFactoryBean(ConsumerMetadata<K, V>, ZookeeperConnect, Properties) - Constructor for class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean: Deprecated.
ConsumerConfigFactoryBean(ConsumerMetadata<K, V>, ZookeeperConnect) - Constructor for class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean: Deprecated.
ConsumerConfiguration<K,V> - Class in org.springframework.integration.kafka.support: Deprecated.
ConsumerConfiguration(ConsumerMetadata<K, V>, ConsumerConnectionProvider, MessageLeftOverTracker<K, V>) - Constructor for class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
ConsumerConnectionProvider - Class in org.springframework.integration.kafka.support: Deprecated.
ConsumerConnectionProvider(ConsumerConfig) - Constructor for class org.springframework.integration.kafka.support.ConsumerConnectionProvider: Deprecated.
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
consumerId - Variable in class org.springframework.integration.kafka.listener.AbstractOffsetManager
ConsumerMetadata<K,V> - Class in org.springframework.integration.kafka.support: Deprecated.
ConsumerMetadata() - Constructor for class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
convertAndSend(String, Integer, Object, Object) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
convertAndSend(String, Object, Object) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
createMessageStreamsForTopic() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
createMessageStreamsForTopicFilter() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.

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
DEFAULT_WAIT_FOR_LEADER_REFRESH_RETRY - Static variable in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
DefaultAcknowledgment - Class in org.springframework.integration.kafka.listener: Default implementation for an Acknowledgment that defers to an underlying OffsetManager.
DefaultAcknowledgment(OffsetManager, Partition, Long) - Constructor for class org.springframework.integration.kafka.listener.DefaultAcknowledgment
DefaultAcknowledgment(OffsetManager, KafkaMessage) - Constructor for class org.springframework.integration.kafka.listener.DefaultAcknowledgment
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
DefaultProducerListener - Class in org.springframework.integration.kafka.support: No-op implementation of @link ProducerListener}, to be used as base class for other implementations.
DefaultProducerListener() - Constructor for class org.springframework.integration.kafka.support.DefaultProducerListener
DELETE_RETENTION - Static variable in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
deleteOffset(Partition) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
deleteOffset(Partition) - Method in interface org.springframework.integration.kafka.listener.OffsetManager: Removes the offset for a given Partition.
deleteOffset(Partition) - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager
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.listener.AbstractOffsetManager
destroy() - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager
destroy() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext: Deprecated.
disconnect(BrokerAddress) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory: Close the connection to the broker
disconnect(BrokerAddress) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory
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
doGetOffset(Partition) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
doGetOffset(Partition) - Method in class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
doGetOffset(Partition) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
doGetOffset(Partition) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
doOnMessage(K, P, KafkaMessageMetadata, Acknowledgment) - Method in class org.springframework.integration.kafka.listener.AbstractDecodingAcknowledgingMessageListener: Process the decoded message
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: Deprecated.
doParse(Element, ParserContext, String) - Method in class org.springframework.integration.kafka.config.xml.KafkaMessageDrivenChannelAdapterParser
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
doRemoveOffset(Partition) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
doRemoveOffset(Partition) - Method in class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
doRemoveOffset(Partition) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
doRemoveOffset(Partition) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
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
doUpdateOffset(Partition, long) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
doUpdateOffset(Partition, long) - Method in class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
doUpdateOffset(Partition, long) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
doUpdateOffset(Partition, long) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager

E

EncoderAdaptingSerializer<T> - Class in org.springframework.integration.kafka.util: An adapter from the pre-0.8.2 Kafka Encoder to the Serializer interface used by the new client.
EncoderAdaptingSerializer(Encoder<T>) - Constructor for class org.springframework.integration.kafka.util.EncoderAdaptingSerializer
ensureTopicCreated(String, String, int, int) - Static method in class org.springframework.integration.kafka.util.TopicUtils: Creates a topic in Kafka or validates that it exists with the requested number of partitions, and returns only after the topic has been fully created
ensureTopicCreated(ZkClient, String, int, Properties, Map<Object, Seq<Object>>) - Static method in class org.springframework.integration.kafka.util.TopicUtils: Creates a topic in Kafka and returns only after the topic has been fully and an produce metadata.
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.listener.KafkaTopicOffsetManager.Key
ErrorHandler - Interface in org.springframework.integration.kafka.listener: Handles errors thrown during the execution of a MessageListener
errorlessTopicMetadataPredicate - Static variable in class org.springframework.integration.kafka.core.DefaultConnectionFactory

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.EarliestTime()) 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: Deprecated.
as of 1.3, only ConnectionFactory.getLeaders(Iterable) should be used
findLeaders(String...) - Method in class org.springframework.integration.kafka.core.DefaultConnection: Deprecated.
flush() - Method in class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
flush() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
flush() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
flush() - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager
fromAddress(String) - Static method in class org.springframework.integration.kafka.core.BrokerAddress
fromBytes(byte[]) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.KeySerializerDecoder
fromBytes(byte[]) - Method in class org.springframework.integration.kafka.listener.LongSerializerDecoder
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

generateKey(Partition) - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
getAdminTaskExecutor() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
getAutoCommitEnable() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getAutoCommitInterval() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getAutoOffsetReset() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getBackOff() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
getBackOff() - Method in interface org.springframework.integration.kafka.core.Configuration: The retry backoff for this client
getBackoffIncrement() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getBatchBytes() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.KafkaConsumerContextParser: Deprecated.
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.
getBufferSize() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
getBufferSize() - Method in interface org.springframework.integration.kafka.core.Configuration: The buffer size for this client
getCharset() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
getClientId() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
getClientId() - Method in interface org.springframework.integration.kafka.core.Configuration: The client name to be used throughout this connection.
getComponentName() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
getComponentType() - Method in class org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource: Deprecated.
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
getCompressionType() - 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: Deprecated.
getConsumerConfigurations() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext: Deprecated.
getConsumerConnector() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
getConsumerConnector() - Method in class org.springframework.integration.kafka.support.ConsumerConnectionProvider: Deprecated.
getConsumerId() - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
getConsumerId() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.Key
getConsumerMetadata() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
getConsumerTimeout() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getConsumerTimeout() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext: Deprecated.
getCurrentCount() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker: Deprecated.
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.
getEncoder() - Method in class org.springframework.integration.kafka.util.EncoderAdaptingSerializer
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
getFetchMetadataTimeout() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
getFetchMetadataTimeout() - Method in interface org.springframework.integration.kafka.core.Configuration: The timeout on fetching metadata (e.g.
getFetchSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getFetchTaskExecutor() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
getGroupId() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
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: Deprecated.
getKeySerializer() - 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: Deprecated.
getMaxSizeInBytes() - Method in class org.springframework.integration.kafka.core.FetchRequest
getMaxWait() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
getMaxWait() - Method in interface org.springframework.integration.kafka.core.Configuration: The maximum amount of time that a server fetch operation will wait before returning (unless minFetchSizeInBytes) are available.
getMessage() - Method in class org.springframework.integration.kafka.core.KafkaMessage
getMessageLeftOverFromPreviousPoll() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker: Deprecated.
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
getMinBytes() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
getMinBytes() - Method in interface org.springframework.integration.kafka.core.Configuration: The minimum amount of data that a server fetch operation will wait for before returning, unless maxWait has elapsed.
getNextOffset() - Method in class org.springframework.integration.kafka.core.KafkaMessageMetadata
getNumberOfStreams() - Method in class org.springframework.integration.kafka.support.TopicFilterConfiguration: Deprecated.
getObject() - Method in class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean: Deprecated.
getObject() - Method in class org.springframework.integration.kafka.support.ProducerFactoryBean
getObjectType() - Method in class org.springframework.integration.kafka.support.ConsumerConfigFactoryBean: Deprecated.
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.AbstractOffsetManager
getOffset(Partition) - Method in interface org.springframework.integration.kafka.listener.OffsetManager: Retrieves the offset for a given Partition
getOffset(Partition) - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager
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
getPartition() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.Key
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
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: Deprecated.
getQueueSize() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
getRebalanceRetriesMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getRecoveryInterval() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
getResult(Partition) - Method in class org.springframework.integration.kafka.core.Result
getResults() - Method in class org.springframework.integration.kafka.core.Result
getSendTimeout() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
getSocketBufferSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getSocketTimeout() - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
getSocketTimeout() - Method in interface org.springframework.integration.kafka.core.Configuration: The socket timeout for this client
getSocketTimeout() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getStopTimeout() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
getStreams() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getTopic() - Method in class org.springframework.integration.kafka.core.Partition
getTopic() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
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: Deprecated.
getTopicFilterConfiguration() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getTopicStreamMap() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getValueClassType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
getValueDecoder() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
getValueSerializer() - 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: Deprecated.
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.listener.KafkaTopicOffsetManager.Key
highestUpdatedOffsets - Variable in class org.springframework.integration.kafka.listener.AbstractOffsetManager

I

init() - Method in class org.springframework.integration.kafka.config.xml.KafkaNamespaceHandler
initialOffsets - Variable in class org.springframework.integration.kafka.listener.AbstractOffsetManager
isAutoCommitOnError() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
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
isLongLived() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer.FetchTask
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: Deprecated.
isSingleton() - Method in class org.springframework.integration.kafka.support.ProducerFactoryBean
isSync() - Method in class org.springframework.integration.kafka.support.ProducerMetadata

K

KafkaConsumerContext<K,V> - Class in org.springframework.integration.kafka.support: Deprecated.
KafkaConsumerContext() - Constructor for class org.springframework.integration.kafka.support.KafkaConsumerContext: Deprecated.
KafkaConsumerContextParser - Class in org.springframework.integration.kafka.config.xml: Deprecated.
KafkaConsumerContextParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaConsumerContextParser: Deprecated.
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: Deprecated.
since 1.3 in favor of KafkaMessageDrivenChannelAdapter
KafkaHighLevelConsumerMessageSource(KafkaConsumerContext<K, V>) - Constructor for class org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource: Deprecated.
KafkaInboundChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml: Deprecated.
KafkaInboundChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaInboundChannelAdapterParser: Deprecated.
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
KafkaMessageDrivenChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml
KafkaMessageDrivenChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaMessageDrivenChannelAdapterParser
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, RichIterable<Partition>) - 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
KafkaNativeOffsetManager - Class in org.springframework.integration.kafka.listener: Implementation of an OffsetManager that uses kafka native 'topic' offset storage.
KafkaNativeOffsetManager(ConnectionFactory, ZookeeperConnect) - Constructor for class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
KafkaNativeOffsetManager(ConnectionFactory, ZookeeperConnect, Map<Partition, Long>) - Constructor for class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
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 - 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 - Class in org.springframework.integration.kafka.outbound
KafkaProducerMessageHandler(KafkaProducerContext) - 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
KafkaTopicOffsetManager - Class in org.springframework.integration.kafka.listener: Implementation of an OffsetManager that uses a Kafka topic as the underlying support.
KafkaTopicOffsetManager(ZookeeperConnect, String) - Constructor for class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
KafkaTopicOffsetManager(ZookeeperConnect, String, Map<Partition, Long>) - Constructor for class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
KafkaTopicOffsetManager.Key - Class in org.springframework.integration.kafka.listener: Wraps the partition and consumer information and will be used as a key on the Kafka topic
KafkaTopicOffsetManager.Key(String, Partition) - Constructor for class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.Key
KafkaTopicOffsetManager.KeySerializerDecoder - Class in org.springframework.integration.kafka.listener
KafkaTopicOffsetManager.KeySerializerDecoder() - Constructor for class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.KeySerializerDecoder

L

log - Variable in class org.springframework.integration.kafka.listener.AbstractOffsetManager
LoggingErrorHandler - Class in org.springframework.integration.kafka.listener
LoggingErrorHandler() - Constructor for class org.springframework.integration.kafka.listener.LoggingErrorHandler
LoggingProducerListener - Class in org.springframework.integration.kafka.support: ProducerListener that logs exceptions thrown when sending messages.
LoggingProducerListener() - Constructor for class org.springframework.integration.kafka.support.LoggingProducerListener
LoggingUtils - Class in org.springframework.integration.kafka.util: Utilities for logging data
LoggingUtils() - Constructor for class org.springframework.integration.kafka.util.LoggingUtils
LongSerializerDecoder - Class in org.springframework.integration.kafka.listener: Kafka Encoder and Decoder for Long values.
LongSerializerDecoder() - Constructor for class org.springframework.integration.kafka.listener.LongSerializerDecoder

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: Deprecated.
MessageLeftOverTracker() - Constructor for class org.springframework.integration.kafka.support.MessageLeftOverTracker: Deprecated.
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
METADATA_VERIFICATION_MAX_INTERVAL - Static variable in class org.springframework.integration.kafka.util.TopicUtils
METADATA_VERIFICATION_RETRY_ATTEMPTS - Static variable in class org.springframework.integration.kafka.util.TopicUtils
METADATA_VERIFICATION_RETRY_BACKOFF_MULTIPLIER - Static variable in class org.springframework.integration.kafka.util.TopicUtils
METADATA_VERIFICATION_RETRY_INITIAL_INTERVAL - Static variable in class org.springframework.integration.kafka.util.TopicUtils
METADATA_VERIFICATION_TIMEOUT - Static variable in class org.springframework.integration.kafka.util.TopicUtils
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

N

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

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
onCompletion(RecordMetadata, Exception) - Method in class org.springframework.integration.kafka.support.ProducerListenerInvokingCallback
onError(String, Integer, Object, Object, Exception) - Method in class org.springframework.integration.kafka.support.DefaultProducerListener
onError(String, Integer, Object, Object, Exception) - Method in class org.springframework.integration.kafka.support.LoggingProducerListener
onError(String, Integer, Object, Object, Exception) - Method in interface org.springframework.integration.kafka.support.ProducerListener: Invoked after an attempt to send a message has failed
onInit() - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
onInit() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
onMessage(KafkaMessage, Acknowledgment) - Method in class org.springframework.integration.kafka.listener.AbstractDecodingAcknowledgingMessageListener
onMessage(KafkaMessage) - Method in class org.springframework.integration.kafka.listener.AbstractDecodingMessageListener
onMessage(KafkaMessage, Acknowledgment) - Method in interface org.springframework.integration.kafka.listener.AcknowledgingMessageListener: Executes when a Kafka message is received
onMessage(KafkaMessage) - Method in interface org.springframework.integration.kafka.listener.MessageListener: Executes when a Kafka message is received
onSuccess(String, Integer, Object, Object, RecordMetadata) - Method in class org.springframework.integration.kafka.support.DefaultProducerListener
onSuccess(String, Integer, Object, Object, RecordMetadata) - Method in interface org.springframework.integration.kafka.support.ProducerListener: Invoked after the successful send of a message (that is, after it has been acknowledged by the broker)
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: Deprecated.
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
PartitionNotFoundException - Exception in org.springframework.integration.kafka.core
PartitionNotFoundException(Partition) - Constructor for exception org.springframework.integration.kafka.core.PartitionNotFoundException
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
ProducerListener - Interface in org.springframework.integration.kafka.support: Listener for handling outbound Kafka messages.
ProducerListenerInvokingCallback - Class in org.springframework.integration.kafka.support: Adapts the Callback interface of the Producer to a ProducerListener.
ProducerListenerInvokingCallback(String, Integer, Object, Object, ProducerListener) - Constructor for class org.springframework.integration.kafka.support.ProducerListenerInvokingCallback
ProducerMetadata<K,V> - Class in org.springframework.integration.kafka.support
ProducerMetadata(String, Class<K>, Class<V>, Serializer<K>, Serializer<V>) - Constructor for class org.springframework.integration.kafka.support.ProducerMetadata
ProducerMetadata.CompressionType - Enum in org.springframework.integration.kafka.support

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: Deprecated.
receive() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
receive() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext: Deprecated.
referenceTimestamp - Variable in class org.springframework.integration.kafka.listener.AbstractOffsetManager
refreshMetadata(Collection<String>) - Method in interface org.springframework.integration.kafka.core.ConnectionFactory: Refresh the cached metadata (i.e.
refreshMetadata(Collection<String>) - Method in class org.springframework.integration.kafka.core.DefaultConnectionFactory
resetOffsets(Collection<Partition>) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
resetOffsets(Collection<Partition>) - Method in interface org.springframework.integration.kafka.listener.OffsetManager: Resets offsets for the given Partitions.
resetOffsets(Collection<Partition>) - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager
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

SEGMENT_BYTES - Static variable in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
send(String, Object, Object) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
send(String, Integer, Object, Object) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
send(String, K, V) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
send(String, Integer, K, V) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
serialize(String, KafkaTopicOffsetManager.Key) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.KeySerializerDecoder
serialize(String, Long) - Method in class org.springframework.integration.kafka.listener.LongSerializerDecoder
serialize(T, DatumWriter<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSerializer
serialize(String, T) - Method in class org.springframework.integration.kafka.util.EncoderAdaptingSerializer
setAdminTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer: The task executor for leader, offset, and partition reassignment updates.
setAutoCommitEnable(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setAutoCommitInterval(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setAutoCommitOffset(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter: Automatically commit the offsets when 'true'.
setAutoCommitOnError(boolean) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer: Whether offsets should be auto acknowledged even when exceptions are thrown during processing.
setAutoOffsetReset(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
setAutoStartup(boolean) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
setBackoff(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration: The retry backoff time for this client
setBackoffIncrement(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setBatchBytes(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: The maximum batch size in bytes for offset writes
setBatchBytes(int) - 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.AbstractConfiguration: The buffer size for this client
setCharset(Charset) - Method in class org.springframework.integration.kafka.support.ProducerMetadata: The character encoding to preform String <-> byte[] conversion instead of general (de)serialization.
setClientId(String) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration: A client name to be used throughout this connection.
setCompressionCodec(ProducerMetadata.CompressionType) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: The compression type for writing to the offset topic
setCompressionType(ProducerMetadata.CompressionType) - 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: Deprecated.
setConsumerId(String) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager: The identifier of a consumer of Kafka messages.
setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext: Deprecated.
setConversionService(ConversionService) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
setCount(int) - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager: How many writes should be aggregated, before invoking the underlying OffsetManager.
setDefaultPartitions(List<Partition>) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
setDefaultTopic(String) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration
setDispatcherTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer: The task executor for invoking the MessageListener
setEnableHeaderRouting(boolean) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler: Enable the use of headers for determining the target topic and partition of outbound messages.
setErrorHandler(ErrorHandler) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
setExecutor(Executor) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
setFetchMetadataTimeout(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration: The timeout on fetching metadata (e.g.
setFetchSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setFetchTaskExecutor(Executor) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer: The task executor for fetch operations.
setGenerateMessageId(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter: Generate Message ids for produced messages.
setGenerateTimestamp(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter: Generate timestamp for produced messages.
setGroupId(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setHighWatermark(long) - Method in class org.springframework.integration.kafka.core.KafkaMessageBatch
setId(int) - Method in class org.springframework.integration.kafka.core.Partition
setIncludeContents(boolean) - Method in class org.springframework.integration.kafka.support.LoggingProducerListener: Whether the log message should include the contents (key and payload).
setKeyDecoder(Decoder<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
setKeyDecoder(Decoder<K>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setMaxContentLogged(int) - Method in class org.springframework.integration.kafka.support.LoggingProducerListener: The maximum amount of data to be logged for either key or password.
setMaxFetch(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
setMaxMessages(int) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
setMaxQueueBufferingTime(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: For how long will producers buffer data before writing to the topic
setMaxSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: Sets the maximum size of a fetch request, allowing to tune the initialization process.
setMaxSizeInBytes(int) - Method in class org.springframework.integration.kafka.core.FetchRequest
setMaxWait(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration: 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(Object) - 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.AbstractConfiguration: The minimum amount of data that a server fetch operation will wait for before returning, unless maxWait 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
setPartitionExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler: Deprecated.
as of 1.3, setPartitionIdExpression(Expression) should be used instead
setPartitionIdExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
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<?, ?>>) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
setProducerListener(ProducerListener) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
setQueuedChunksMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
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: Deprecated.
setRecoveryInterval(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer: Specify the interval to control the frequency of the consumer's attempts to reconnect after connection is lost.
setReferenceTimestamp(long) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager: A timestamp to be used for resetting initial offsets
setReplicationFactor(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: The replication factor of the offset topic
setRequiredAcks(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: The number of required acks on write operations
setRetentionTime(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: How long are dead records retained in the offset topic
setRetryTemplate(RetryTemplate) - Method in class org.springframework.integration.kafka.listener.KafkaNativeOffsetManager
setSegmentSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager: The size of a segment in the offset topic
setSendTimeout(int) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
setShutdownTimeout(int) - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager: The timeout that WindowingOffsetManager.close() and WindowingOffsetManager.destroy() operations will wait for receiving a confirmation that the underlying writes have been processed.
setSocketBufferSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setSocketTimeout(int) - Method in class org.springframework.integration.kafka.core.AbstractConfiguration: The socket timeout for this client
setSocketTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setStopTimeout(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer: The timeout for waiting for each concurrent MessageListener to finish on stopping.
setStreams(int) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setSync(boolean) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
setTimespan(long) - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager: The timespan for aggregating write operations, before invoking the underlying OffsetManager.
setTopic(String) - Method in class org.springframework.integration.kafka.core.Partition
setTopic(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setTopicExpression(Expression) - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
setTopicFilterConfiguration(TopicFilterConfiguration) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setTopicStreamMap(Map<String, Integer>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
setUseMessageBuilderFactory(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter: Use the MessageBuilderFactory returned by IntegrationObjectSupport.getMessageBuilderFactory() to create messages.
setValueDecoder(Decoder<V>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata: Deprecated.
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: Deprecated.
shutdown() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration: Deprecated.
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 - Class in org.springframework.integration.kafka.serializer.common
StringEncoder() - Constructor for class org.springframework.integration.kafka.serializer.common.StringEncoder
StringEncoder(String) - 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(String) - 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: Deprecated.
TopicFilterConfiguration(String, int, boolean) - Constructor for class org.springframework.integration.kafka.support.TopicFilterConfiguration: Deprecated.
TopicNotFoundException - Exception in org.springframework.integration.kafka.core
TopicNotFoundException(String) - Constructor for exception org.springframework.integration.kafka.core.TopicNotFoundException
TopicUtils - Class in org.springframework.integration.kafka.util: Utilities for interacting with Kafka topics
TopicUtils() - Constructor for class org.springframework.integration.kafka.util.TopicUtils
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: Deprecated.

U

updateOffset(Partition, long) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
updateOffset(Partition, long) - Method in interface org.springframework.integration.kafka.listener.OffsetManager: Updates the offset for a given Partition
updateOffset(Partition, long) - Method in class org.springframework.integration.kafka.listener.WindowingOffsetManager

V

valueOf(String) - Static method in enum org.springframework.integration.kafka.support.ProducerMetadata.CompressionType: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.integration.kafka.support.ProducerMetadata.CompressionType: Returns an array containing the constants of this enum type, in the order they are declared.

W

WindowingOffsetManager - Class in org.springframework.integration.kafka.listener: An OffsetManager that aggregates writes over a time or count window, using an underlying delegate to do the actual operations.
WindowingOffsetManager(OffsetManager) - Constructor for class org.springframework.integration.kafka.listener.WindowingOffsetManager

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(String) - Constructor for class org.springframework.integration.kafka.core.ZookeeperConfiguration
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
ZookeeperConnect(String) - 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 N O P Q R S T U V W Z