Spring Integration Kafka Support

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

java.lang.Object
  extended by org.springframework.integration.kafka.support.ConsumerMetadata<K,V>
All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean

public class ConsumerMetadata<K,V>
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean

Since:
0.5
Author:
Soby Chacko, Rajasekar Elango

Constructor Summary
ConsumerMetadata()
           
 
Method Summary
 void afterPropertiesSet()
           
 java.lang.String getAutoCommitEnable()
           
 java.lang.String getAutoCommitInterval()
           
 java.lang.String getAutoOffsetReset()
           
 java.lang.String getBackoffIncrement()
           
 java.lang.String getConsumerTimeout()
           
 java.lang.String getFetchSize()
           
 java.lang.String getGroupId()
           
 kafka.serializer.Decoder<K> getKeyDecoder()
           
 java.lang.String getQueuedChunksMax()
           
 java.lang.String getRebalanceRetriesMax()
           
 java.lang.String getSocketBufferSize()
           
 java.lang.String getSocketTimeout()
           
 int getStreams()
           
 java.lang.String getTopic()
           
 TopicFilterConfiguration getTopicFilterConfiguration()
           
 java.util.Map<java.lang.String,java.lang.Integer> getTopicStreamMap()
           
 kafka.serializer.Decoder<V> getValueDecoder()
           
 void setAutoCommitEnable(java.lang.String autoCommitEnable)
           
 void setAutoCommitInterval(java.lang.String autoCommitInterval)
           
 void setAutoOffsetReset(java.lang.String autoOffsetReset)
           
 void setBackoffIncrement(java.lang.String backoffIncrement)
           
 void setConsumerTimeout(java.lang.String consumerTimeout)
           
 void setFetchSize(java.lang.String fetchSize)
           
 void setGroupId(java.lang.String groupId)
           
 void setKeyDecoder(kafka.serializer.Decoder<K> keyDecoder)
           
 void setQueuedChunksMax(java.lang.String queuedChunksMax)
           
 void setRebalanceRetriesMax(java.lang.String rebalanceRetriesMax)
           
 void setSocketBufferSize(java.lang.String socketBufferSize)
           
 void setSocketTimeout(java.lang.String socketTimeout)
           
 void setStreams(int streams)
           
 void setTopic(java.lang.String topic)
           
 void setTopicFilterConfiguration(TopicFilterConfiguration topicFilterConfiguration)
           
 void setTopicStreamMap(java.util.Map<java.lang.String,java.lang.Integer> topicStreamMap)
           
 void setValueDecoder(kafka.serializer.Decoder<V> valueDecoder)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConsumerMetadata

public ConsumerMetadata()
Method Detail

getGroupId

public java.lang.String getGroupId()

setGroupId

public void setGroupId(java.lang.String groupId)

getSocketTimeout

public java.lang.String getSocketTimeout()

setSocketTimeout

public void setSocketTimeout(java.lang.String socketTimeout)

getSocketBufferSize

public java.lang.String getSocketBufferSize()

setSocketBufferSize

public void setSocketBufferSize(java.lang.String socketBufferSize)

getFetchSize

public java.lang.String getFetchSize()

setFetchSize

public void setFetchSize(java.lang.String fetchSize)

getBackoffIncrement

public java.lang.String getBackoffIncrement()

setBackoffIncrement

public void setBackoffIncrement(java.lang.String backoffIncrement)

getQueuedChunksMax

public java.lang.String getQueuedChunksMax()

setQueuedChunksMax

public void setQueuedChunksMax(java.lang.String queuedChunksMax)

getAutoCommitEnable

public java.lang.String getAutoCommitEnable()

setAutoCommitEnable

public void setAutoCommitEnable(java.lang.String autoCommitEnable)

getAutoCommitInterval

public java.lang.String getAutoCommitInterval()

setAutoCommitInterval

public void setAutoCommitInterval(java.lang.String autoCommitInterval)

getAutoOffsetReset

public java.lang.String getAutoOffsetReset()

setAutoOffsetReset

public void setAutoOffsetReset(java.lang.String autoOffsetReset)

getRebalanceRetriesMax

public java.lang.String getRebalanceRetriesMax()

setRebalanceRetriesMax

public void setRebalanceRetriesMax(java.lang.String rebalanceRetriesMax)

getConsumerTimeout

public java.lang.String getConsumerTimeout()

setConsumerTimeout

public void setConsumerTimeout(java.lang.String consumerTimeout)

getTopic

public java.lang.String getTopic()

setTopic

public void setTopic(java.lang.String topic)

getStreams

public int getStreams()

setStreams

public void setStreams(int streams)

getValueDecoder

public kafka.serializer.Decoder<V> getValueDecoder()

setValueDecoder

public void setValueDecoder(kafka.serializer.Decoder<V> valueDecoder)

getKeyDecoder

public kafka.serializer.Decoder<K> getKeyDecoder()

setKeyDecoder

public void setKeyDecoder(kafka.serializer.Decoder<K> keyDecoder)

getTopicStreamMap

public java.util.Map<java.lang.String,java.lang.Integer> getTopicStreamMap()

setTopicStreamMap

public void setTopicStreamMap(java.util.Map<java.lang.String,java.lang.Integer> topicStreamMap)

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception
Specified by:
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
Throws:
java.lang.Exception

getTopicFilterConfiguration

public TopicFilterConfiguration getTopicFilterConfiguration()

setTopicFilterConfiguration

public void setTopicFilterConfiguration(TopicFilterConfiguration topicFilterConfiguration)

Spring Integration Kafka Support