A B C D E F G H I K L M N O P Q R S T U V 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
 
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.listener.KafkaTopicOffsetManager
 
afterPropertiesSet() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
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
 
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
 
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.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.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
 
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
 
consumerId - Variable in class org.springframework.integration.kafka.listener.AbstractOffsetManager
 
ConsumerMetadata<K,V> - Class in org.springframework.integration.kafka.support
 
ConsumerMetadata() - Constructor for class org.springframework.integration.kafka.support.ConsumerMetadata
 
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
 
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
 
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
 
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.
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.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
 
doGetOffset(Partition) - Method in class org.springframework.integration.kafka.listener.AbstractOffsetManager
 
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
 
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.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.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
 
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
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.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.KafkaTopicOffsetManager
 
flush() - Method in class org.springframework.integration.kafka.listener.MetadataStoreOffsetManager
 
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
 
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
 
getBatchBytes() - 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.
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
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
 
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
 
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.AbstractOffsetManager
 
getConsumerId() - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager.Key
 
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.
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
 
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
 
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
 
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
 
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
 
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.AbstractOffsetManager
 
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
 
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
 
getQueueSize() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
 
getRebalanceRetriesMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
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.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
 
getStopTimeout() - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
 
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
 
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
 
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
 
hashCode() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
 
hashCode() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
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
 
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
 
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) - 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 - 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
 
keyFunction - Static variable in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
 

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
 
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
 
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
 
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
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
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
 
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
 
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
 
receive() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
 
receive() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
 
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.
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 and offset updates
setAutoCommitEnable(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setAutoCommitInterval(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setAutoCommitOffset(boolean) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
Automatically commit the offsets when 'true'.
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
 
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
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
 
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
 
setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
 
setConversionService(ConversionService) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
 
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
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.AbstractConfiguration
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
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
 
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
 
setKeyDecoder(Decoder<?>) - Method in class org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter
 
setKeyDecoder(Decoder<K>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setMaxFetch(int) - Method in class org.springframework.integration.kafka.listener.KafkaMessageListenerContainer
 
setMaxMessages(int) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
 
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
 
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
 
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.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
setSegmentSize(int) - Method in class org.springframework.integration.kafka.listener.KafkaTopicOffsetManager
The size of a segment in the offset topic
setSocketBufferSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
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
 
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
 
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
 
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
 
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 - 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
 
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
 
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
 

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

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.

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 Z