JavaScript is disabled on your browser.
Overview
Package
Class
Tree
Deprecated
Index
Help
Spring Integration Kafka Support
Prev
Next
Frames
No Frames
All Classes
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
Overview
Package
Class
Tree
Deprecated
Index
Help
Spring Integration Kafka Support
Prev
Next
Frames
No Frames
All Classes