public class ConsumerMetadata<K,V>
extends java.lang.Object
implements org.springframework.beans.factory.InitializingBean
Constructor and Description |
---|
ConsumerMetadata() |
Modifier and Type | Method and Description |
---|---|
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) |
public java.lang.String getGroupId()
public void setGroupId(java.lang.String groupId)
public java.lang.String getSocketTimeout()
public void setSocketTimeout(java.lang.String socketTimeout)
public java.lang.String getSocketBufferSize()
public void setSocketBufferSize(java.lang.String socketBufferSize)
public java.lang.String getFetchSize()
public void setFetchSize(java.lang.String fetchSize)
public java.lang.String getBackoffIncrement()
public void setBackoffIncrement(java.lang.String backoffIncrement)
public java.lang.String getQueuedChunksMax()
public void setQueuedChunksMax(java.lang.String queuedChunksMax)
public java.lang.String getAutoCommitEnable()
public void setAutoCommitEnable(java.lang.String autoCommitEnable)
public java.lang.String getAutoCommitInterval()
public void setAutoCommitInterval(java.lang.String autoCommitInterval)
public java.lang.String getAutoOffsetReset()
public void setAutoOffsetReset(java.lang.String autoOffsetReset)
public java.lang.String getRebalanceRetriesMax()
public void setRebalanceRetriesMax(java.lang.String rebalanceRetriesMax)
public java.lang.String getConsumerTimeout()
public void setConsumerTimeout(java.lang.String consumerTimeout)
public java.lang.String getTopic()
public void setTopic(java.lang.String topic)
public int getStreams()
public void setStreams(int streams)
public kafka.serializer.Decoder<V> getValueDecoder()
public void setValueDecoder(kafka.serializer.Decoder<V> valueDecoder)
public kafka.serializer.Decoder<K> getKeyDecoder()
public void setKeyDecoder(kafka.serializer.Decoder<K> keyDecoder)
public java.util.Map<java.lang.String,java.lang.Integer> getTopicStreamMap()
public void setTopicStreamMap(java.util.Map<java.lang.String,java.lang.Integer> topicStreamMap)
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public TopicFilterConfiguration getTopicFilterConfiguration()
public void setTopicFilterConfiguration(TopicFilterConfiguration topicFilterConfiguration)