com.taobao.metamorphosis.client.extension.spring
类 MetaqTopic

java.lang.Object
  com.taobao.metamorphosis.client.extension.spring.MetaqTopic

public class MetaqTopic
extends Object

A metaq topic for consumer.

从以下版本开始：

1.4.5

作者：

dennis

构造方法摘要

MetaqTopic()

MetaqTopic(String topic, int maxBufferSize, ConsumerConfig consumerConfig)

方法摘要

boolean	equals(Object obj)
long	getCommitOffsetPeriodInMills()
ConsumerConfig	getConsumerConfig()
String	getConsumerId()
int	getFetchRunnerCount()
long	getFetchTimeoutInMills()
String	getGroup()
LoadBalanceStrategy.Type	getLoadBalanceStrategyType()
int	getMaxBufferSize()
long	getMaxDelayFetchTimeInMills()
int	getMaxFetchRetries()
int	getMaxIncreaseFetchDataRetries()
long	getOffset()
String	getPartition()
Properties	getPartitionsInfo()
long	getRecoverMessageIntervalInMills()
int	getRecoverThreadCount()
String	getServerUrl()
String	getTopic()
ZkUtils.ZKConfig	getZkConfig()
int	hashCode()
boolean	isAlwaysConsumeFromMaxOffset()
void	setAlwaysConsumeFromMaxOffset(boolean always)
void	setCommitOffsetPeriodInMills(long commitOffsetPeriodInMills)
void	setConsumerConfig(ConsumerConfig consumerConfig)
void	setConsumerId(String consumerId)
void	setFetchRunnerCount(int fetchRunnerCount)
void	setFetchTimeoutInMills(long fetchTimeoutInMills)
void	setGroup(String group)
void	setLoadBalanceStrategyType(LoadBalanceStrategy.Type loadBalanceStrategyType)
void	setMaxBufferSize(int maxBufferSize)
void	setMaxDelayFetchTimeInMills(long maxDelayFetchTimeInMills)
void	setMaxFetchRetries(int maxFetchRetries)
void	setMaxIncreaseFetchDataRetries(int maxFetchRetriesForDataNotEnough)
void	setOffset(long offset)
void	setPartition(String partition)
void	setPartitionsInfo(Properties partitionsInfo)
void	setRecoverMessageIntervalInMills(long recoverMessageIntervalInMills)
void	setRecoverThreadCount(int recoverThreadCount)
void	setServerUrl(String serverUrl)
void	setTopic(String topic)
void	setZkConfig(ZkUtils.ZKConfig zkConfig)

从类 java.lang.Object 继承的方法

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

构造方法详细信息

MetaqTopic

public MetaqTopic(String topic,
                  int maxBufferSize,
                  ConsumerConfig consumerConfig)

MetaqTopic

public MetaqTopic()

方法详细信息

getMaxBufferSize

public int getMaxBufferSize()

setMaxBufferSize

public void setMaxBufferSize(int maxBufferSize)

hashCode

public int hashCode()

覆盖：

类 Object 中的 hashCode

equals

public boolean equals(Object obj)

覆盖：

类 Object 中的 equals

getConsumerConfig

public ConsumerConfig getConsumerConfig()

setConsumerConfig

public void setConsumerConfig(ConsumerConfig consumerConfig)

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getRecoverThreadCount

public int getRecoverThreadCount()

setRecoverThreadCount

public void setRecoverThreadCount(int recoverThreadCount)

getRecoverMessageIntervalInMills

public long getRecoverMessageIntervalInMills()

setRecoverMessageIntervalInMills

public void setRecoverMessageIntervalInMills(long recoverMessageIntervalInMills)

getZkConfig

public ZkUtils.ZKConfig getZkConfig()

setZkConfig

public void setZkConfig(ZkUtils.ZKConfig zkConfig)

getMaxFetchRetries

public int getMaxFetchRetries()

isAlwaysConsumeFromMaxOffset

public boolean isAlwaysConsumeFromMaxOffset()

getServerUrl

public String getServerUrl()

setMaxFetchRetries

public void setMaxFetchRetries(int maxFetchRetries)

setServerUrl

public void setServerUrl(String serverUrl)

getMaxIncreaseFetchDataRetries

public int getMaxIncreaseFetchDataRetries()

setMaxIncreaseFetchDataRetries

public void setMaxIncreaseFetchDataRetries(int maxFetchRetriesForDataNotEnough)

setPartitionsInfo

public void setPartitionsInfo(Properties partitionsInfo)

getPartitionsInfo

public Properties getPartitionsInfo()

getFetchRunnerCount

public int getFetchRunnerCount()

getOffset

public long getOffset()

setOffset

public void setOffset(long offset)

setAlwaysConsumeFromMaxOffset

public void setAlwaysConsumeFromMaxOffset(boolean always)

getGroup

public String getGroup()

setGroup

public void setGroup(String group)

getPartition

public String getPartition()

setPartition

public void setPartition(String partition)

getConsumerId

public String getConsumerId()

setConsumerId

public void setConsumerId(String consumerId)

getFetchTimeoutInMills

public long getFetchTimeoutInMills()

setFetchTimeoutInMills

public void setFetchTimeoutInMills(long fetchTimeoutInMills)

getMaxDelayFetchTimeInMills

public long getMaxDelayFetchTimeInMills()

setMaxDelayFetchTimeInMills

public void setMaxDelayFetchTimeInMills(long maxDelayFetchTimeInMills)

setFetchRunnerCount

public void setFetchRunnerCount(int fetchRunnerCount)

getCommitOffsetPeriodInMills

public long getCommitOffsetPeriodInMills()

setCommitOffsetPeriodInMills

public void setCommitOffsetPeriodInMills(long commitOffsetPeriodInMills)

getLoadBalanceStrategyType

public LoadBalanceStrategy.Type getLoadBalanceStrategyType()

setLoadBalanceStrategyType

public void setLoadBalanceStrategyType(LoadBalanceStrategy.Type loadBalanceStrategyType)