接口 com.taobao.metamorphosis.client.consumer.storage.OffsetStorage
的使用

使用 OffsetStorage 的软件包

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

com.taobao.metamorphosis.client 中 OffsetStorage 的使用

参数类型为 OffsetStorage 的 com.taobao.metamorphosis.client 中的方法

MessageConsumer	MetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage)
MessageConsumer	MessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage) 创建消息消费者，使用指定的offset存储器
protected MessageConsumer	MetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, RecoverManager recoverManager0)

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

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

OffsetStorage	SimpleMessageConsumer.getOffsetStorage()
OffsetStorage	MessageConsumer.getOffsetStorage() 返回此消费者使用的offset存储器，可共享给其他消费者

参数类型为 OffsetStorage 的 com.taobao.metamorphosis.client.consumer 中的方法

void	ConsumerZooKeeper.registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy) 注册订阅者

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

ConsumerZooKeeper.ZKLoadRebalanceListener(FetchManager fetchManager, MetaZookeeper.ZKGroupDirs dirs, String consumerIdString, ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, LoadBalanceStrategy loadBalanceStrategy)

SimpleMessageConsumer(MetaMessageSessionFactory messageSessionFactory, RemotingClientWrapper remotingClient, ConsumerConfig consumerConfig, ConsumerZooKeeper consumerZooKeeper, ProducerZooKeeper producerZooKeeper, SubscribeInfoManager subscribeInfoManager, RecoverManager recoverManager, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)

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

实现 OffsetStorage 的 com.taobao.metamorphosis.client.consumer.storage 中的类

class	LocalOffsetStorage 本地offset存储，存储在磁盘，默认存储在$HOME/.meta_offsets文件中
class	MysqlOffsetStorage 基于mysql数据库的offset存储器
class	TairOffsetStorage 基于Tair的offset保存期
class	ZkOffsetStorage 基于zk的offset存储器

com.taobao.metamorphosis.client.extension 中 OffsetStorage 的使用

参数类型为 OffsetStorage 的 com.taobao.metamorphosis.client.extension 中的方法

MessageConsumer	OrderedMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage)
MessageConsumer	ExtMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConsumerRecoverType recoverType)
MessageConsumer	ExtMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, OffsetStorage offsetStorage, ConsumerRecoverType recoverType) 创建消费者

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

实现 OffsetStorage 的 com.taobao.metamorphosis.metaslave 中的类

class

SlaveOffsetStorage 从slave消息文件中load offset,没load到时从master查询最小offset

参数类型为 OffsetStorage 的 com.taobao.metamorphosis.metaslave 中的方法

void	SlaveConsumerZooKeeper.registerConsumer(ConsumerConfig consumerConfig, FetchManager fetchManager, ConcurrentHashMap<String,SubscriberInfo> topicSubcriberRegistry, OffsetStorage offsetStorage, LoadBalanceStrategy loadBalanceStrategy)