Spring Integration Kafka Support
A B C D E F G H I K M O P Q R S T Z 

A

addMessageAndMetadata(MessageAndMetadata<K, V>) - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker
 
afterPropertiesSet() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
afterPropertiesSet() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
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
 
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
 

C

clearMessagesLeftOver() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker
 
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
 
ConsumerMetadata<K,V> - Class in org.springframework.integration.kafka.support
 
ConsumerMetadata() - Constructor for class org.springframework.integration.kafka.support.ConsumerMetadata
 
createMessageStreamsForTopic() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
 
createMessageStreamsForTopicFilter() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
 

D

deserialize(byte[], DatumReader<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSerializer
 
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.kafka.config.xml.KafkaConsumerContextParser
 
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.kafka.config.xml.KafkaProducerContextParser
 
doParse(Element, ParserContext, BeanDefinitionBuilder) - Method in class org.springframework.integration.kafka.config.xml.ZookeeperConnectParser
 

E

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

F

FETCH_SIZE - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
 
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
 

G

getAutoCommitEnable() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getAutoCommitInterval() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getAutoOffsetReset() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getBackoffIncrement() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getBatchNumMessages() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.KafkaConsumerContextParser
 
getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.KafkaProducerContextParser
 
getBeanClass(Element) - Method in class org.springframework.integration.kafka.config.xml.ZookeeperConnectParser
 
getComponentType() - Method in class org.springframework.integration.kafka.inbound.KafkaHighLevelConsumerMessageSource
 
getCompressionCodec() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
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
 
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
 
getFetchSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getGroupId() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getKafkaProducerContext() - Method in class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
 
getKeyClassType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
getKeyDecoder() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getKeyEncoder() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
getMaxMessages() - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
 
getMessageLeftOverFromPreviousPoll() - Method in class org.springframework.integration.kafka.support.MessageLeftOverTracker
 
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
 
getPartitioner() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
getProducerMetadata() - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
 
getProducerProperties() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
 
getQueuedChunksMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getRebalanceRetriesMax() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getSocketBufferSize() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getSocketTimeout() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getStreams() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getTopic() - Method in class org.springframework.integration.kafka.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
 
getTopicsConfiguration() - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
 
getTopicStreamMap() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getValueClassType() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
getValueDecoder() - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
getValueEncoder() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
getZkConnect() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
getZkConnectionTimeout() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
getZkSessionTimeout() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
getZkSyncTime() - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
getZookeeperConnect() - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
 
GROUP_ID - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
 

H

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

I

init() - Method in class org.springframework.integration.kafka.config.xml.KafkaNamespaceHandler
 
isAsync() - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
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.
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
 
KafkaNamespaceHandler - Class in org.springframework.integration.kafka.config.xml
The namespace handler for the Kafka namespace
KafkaNamespaceHandler() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaNamespaceHandler
 
KafkaOutboundChannelAdapterParser - Class in org.springframework.integration.kafka.config.xml
 
KafkaOutboundChannelAdapterParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaOutboundChannelAdapterParser
 
KafkaProducerContext<K,V> - Class in org.springframework.integration.kafka.support
 
KafkaProducerContext() - Constructor for class org.springframework.integration.kafka.support.KafkaProducerContext
 
KafkaProducerContextParser - Class in org.springframework.integration.kafka.config.xml
 
KafkaProducerContextParser() - Constructor for class org.springframework.integration.kafka.config.xml.KafkaProducerContextParser
 
KafkaProducerMessageHandler<K,V> - Class in org.springframework.integration.kafka.outbound
 
KafkaProducerMessageHandler(KafkaProducerContext<K, V>) - Constructor for class org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler
 

M

MessageLeftOverTracker<K,V> - Class in org.springframework.integration.kafka.support
 
MessageLeftOverTracker() - Constructor for class org.springframework.integration.kafka.support.MessageLeftOverTracker
 

O

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

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
 
ProducerConfiguration<K,V> - Class in org.springframework.integration.kafka.support
 
ProducerConfiguration(ProducerMetadata<K, V>, Producer<K, V>) - Constructor for class org.springframework.integration.kafka.support.ProducerConfiguration
 
ProducerFactoryBean<K,V> - Class in org.springframework.integration.kafka.support
 
ProducerFactoryBean(ProducerMetadata<K, V>, String, Properties) - Constructor for class org.springframework.integration.kafka.support.ProducerFactoryBean
 
ProducerFactoryBean(ProducerMetadata<K, V>, String) - Constructor for class org.springframework.integration.kafka.support.ProducerFactoryBean
 
ProducerMetadata<K,V> - Class in org.springframework.integration.kafka.support
 
ProducerMetadata(String) - Constructor for class org.springframework.integration.kafka.support.ProducerMetadata
 

Q

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

R

REBALANCE_RETRIES_MAX - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
 
receive() - 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
 

S

send(Message<?>) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
 
send(Message<?>) - Method in class org.springframework.integration.kafka.support.ProducerConfiguration
 
serialize(T, DatumWriter<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSerializer
 
setAsync(boolean) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setAutoCommitEnable(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setAutoCommitInterval(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setAutoOffsetReset(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setBackoffIncrement(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setBatchNumMessages(String) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setBeanFactory(BeanFactory) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
 
setBeanFactory(BeanFactory) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
 
setCompressionCodec(String) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setConsumerTimeout(String) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
 
setEncoding(String) - Method in class org.springframework.integration.kafka.serializer.common.StringEncoder
 
setFetchSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setGroupId(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setKeyClassType(Class<K>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setKeyDecoder(Decoder<K>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setKeyEncoder(Encoder<K>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setMaxMessages(int) - Method in class org.springframework.integration.kafka.support.ConsumerConfiguration
 
setPartitioner(Partitioner<K>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setProducerProperties(Properties) - Method in class org.springframework.integration.kafka.support.KafkaProducerContext
 
setQueuedChunksMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setRebalanceRetriesMax(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setSocketBufferSize(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setSocketTimeout(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setStreams(int) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setTopic(String) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setTopicFilterConfiguration(TopicFilterConfiguration) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setTopicStreamMap(Map<String, Integer>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setValueClassType(Class<V>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setValueDecoder(Decoder<V>) - Method in class org.springframework.integration.kafka.support.ConsumerMetadata
 
setValueEncoder(Encoder<V>) - Method in class org.springframework.integration.kafka.support.ProducerMetadata
 
setZkConnect(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
setZkConnectionTimeout(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
setZkSessionTimeout(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
setZkSyncTime(String) - Method in class org.springframework.integration.kafka.support.ZookeeperConnect
 
setZookeeperConnect(ZookeeperConnect) - Method in class org.springframework.integration.kafka.support.KafkaConsumerContext
 
SOCKET_BUFFER_SIZE - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
 
SOCKET_TIMEOUT - Static variable in class org.springframework.integration.kafka.core.KafkaConsumerDefaults
 
StringEncoder<T> - Class in org.springframework.integration.kafka.serializer.common
 
StringEncoder() - Constructor for class org.springframework.integration.kafka.serializer.common.StringEncoder
 

T

toBytes(T, DatumWriter<T>) - Method in class org.springframework.integration.kafka.serializer.avro.AvroDatumSupport
 
toBytes(T) - Method in class org.springframework.integration.kafka.serializer.avro.AvroReflectDatumBackedKafkaEncoder
 
toBytes(T) - Method in class org.springframework.integration.kafka.serializer.avro.AvroSpecificDatumBackedKafkaEncoder
 
toBytes(Object) - Method in class org.springframework.integration.kafka.serializer.common.StringEncoder
 
TopicFilterConfiguration - Class in org.springframework.integration.kafka.support
 
TopicFilterConfiguration(String, int, boolean) - Constructor for class org.springframework.integration.kafka.support.TopicFilterConfiguration
 
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
 

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
 
ZookeeperConnect - Class in org.springframework.integration.kafka.support
 
ZookeeperConnect() - Constructor for class org.springframework.integration.kafka.support.ZookeeperConnect
 
ZookeeperConnectDefaults - Class in org.springframework.integration.kafka.core
 
ZookeeperConnectParser - Class in org.springframework.integration.kafka.config.xml
 
ZookeeperConnectParser() - Constructor for class org.springframework.integration.kafka.config.xml.ZookeeperConnectParser
 
A B C D E F G H I K M O P Q R S T Z 
Spring Integration Kafka Support