类 com.taobao.metamorphosis.client.consumer.TopicPartitionRegInfo
的使用

使用 TopicPartitionRegInfo 的软件包

com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.client.consumer.storage
com.taobao.metamorphosis.metaslave

com.taobao.metamorphosis.client.consumer 中 TopicPartitionRegInfo 的使用

返回 TopicPartitionRegInfo 的 com.taobao.metamorphosis.client.consumer 中的方法

TopicPartitionRegInfo	TopicPartitionRegInfo.clone(MessageIterator it)
static TopicPartitionRegInfo	SimpleFetchManager.currentTopicRegInfo() Returns current thread processing message's TopicPartitionRegInfo.
TopicPartitionRegInfo	FetchRequest.getTopicPartitionRegInfo()

参数类型为 TopicPartitionRegInfo 的 com.taobao.metamorphosis.client.consumer 中的构造方法

FetchRequest(Broker broker, long delay, TopicPartitionRegInfo topicPartitionRegInfo, int maxSize)

com.taobao.metamorphosis.client.consumer.storage 中 TopicPartitionRegInfo 的使用

返回 TopicPartitionRegInfo 的 com.taobao.metamorphosis.client.consumer.storage 中的方法

TopicPartitionRegInfo	ZkOffsetStorage.load(String topic, String group, Partition partition)
TopicPartitionRegInfo	TairOffsetStorage.load(String topic, String group, Partition partition)
TopicPartitionRegInfo	OffsetStorage.load(String topic, String group, Partition partition) 加载一条消费者的订阅信息，如果不存在返回null
TopicPartitionRegInfo	MysqlOffsetStorage.load(String topic, String group, Partition partition)
TopicPartitionRegInfo	LocalOffsetStorage.load(String topic, String group, Partition partition)

类型变量类型为 TopicPartitionRegInfo 的 com.taobao.metamorphosis.client.consumer.storage 中的方法参数

void	ZkOffsetStorage.commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)
void	TairOffsetStorage.commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)
void	OffsetStorage.commitOffset(String group, Collection<TopicPartitionRegInfo> infoList) 保存offset到存储
void	MysqlOffsetStorage.commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)
void	LocalOffsetStorage.commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)

com.taobao.metamorphosis.metaslave 中 TopicPartitionRegInfo 的使用

返回 TopicPartitionRegInfo 的 com.taobao.metamorphosis.metaslave 中的方法

TopicPartitionRegInfo

SlaveOffsetStorage.load(String topic, String group, Partition partition)

类型变量类型为 TopicPartitionRegInfo 的 com.taobao.metamorphosis.metaslave 中的方法参数

void	SlaveOffsetStorage.commitOffset(String group, Collection<TopicPartitionRegInfo> infoList)