com.taobao.metamorphosis.client.consumer
类 TopicPartitionRegInfo

java.lang.Object
  com.taobao.metamorphosis.client.consumer.TopicPartitionRegInfo

所有已实现的接口：

Serializable

public class TopicPartitionRegInfo
extends Object
implements Serializable

订阅消息的注册信息

作者：

boyan

另请参见：

序列化表格

构造方法摘要

TopicPartitionRegInfo(String topic, Partition partition, long offset)

TopicPartitionRegInfo(String topic, Partition partition, long offset, long messageId)

方法摘要

TopicPartitionRegInfo	clone(MessageIterator it)
boolean	equals(Object obj)
long	getMessageId()
AtomicLong	getOffset()
Partition	getPartition()
String	getTopic()
int	hashCode()
boolean	isModified()
void	setMessageId(long messageId)
void	setModified(boolean modified)
void	setPartition(Partition partition)
void	setTopic(String topic)

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

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

构造方法详细信息

TopicPartitionRegInfo

public TopicPartitionRegInfo(String topic,
                             Partition partition,
                             long offset)

TopicPartitionRegInfo

public TopicPartitionRegInfo(String topic,
                             Partition partition,
                             long offset,
                             long messageId)

方法详细信息

clone

public TopicPartitionRegInfo clone(MessageIterator it)

isModified

public boolean isModified()

setModified

public void setModified(boolean modified)

getMessageId

public long getMessageId()

setMessageId

public void setMessageId(long messageId)

hashCode

public int hashCode()

覆盖：

类 Object 中的 hashCode

equals

public boolean equals(Object obj)

覆盖：

类 Object 中的 equals

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getPartition

public Partition getPartition()

setPartition

public void setPartition(Partition partition)

getOffset

public AtomicLong getOffset()