org.springframework.integration.kafka.support
Class ConsumerMetadata<K,V>
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConsumerMetadata
public ConsumerMetadata()
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)