软件包 com.taobao.metamorphosis.client.consumer

接口摘要

FetchManager	Fetch请求管理器接口
InnerConsumer	不对外提供的consumer接口，用于提供给Fetch使用
LoadBalanceStrategy	Consumer的balance策略
MessageConsumer	消息消费者，线程安全，推荐复用
MessageIdCache	Message id cache to prevent duplicated messages for the same consumer group.
MessageListener	异步消息监听器
RecoverManager	消费端的Recover管理器
RejectConsumptionHandler	Created with IntelliJ IDEA.

类摘要

AbstractRecoverManager
ConcurrentLRUHashMap	Concurrent LRU map
ConsisHashStrategy	基于一致性哈希的负载均衡策略： 将所有consumer组织成一个环 将所有分区根据hash值插入到环上 获取指定consumer前面，前一个consumer之后的分区列表作为结果
ConsumerConfig	消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。
ConsumerZooKeeper	Consumer与Zookeeper交互
DefaultLoadBalanceStrategy	默认的负载均衡策略，尽量使得负载在所有consumer之间平均分配，consumer之间分配的分区数差距不大于1
FetchRequest	一次获取请求
MessageIterator	已过时。 Please use com.taobao.metamorphosis.consumer.MessageIterator instead.
RecoverStorageManager	Recover存储管理器
SimpleFetchManager	消息抓取管理器的实现
SimpleMessageConsumer	消息消费者基类
SimpleMessageConsumer.DropPolicy	Created with IntelliJ IDEA.
SimpleMessageConsumer.LocalRecoverPolicy	Created with IntelliJ IDEA.
SubscribeInfoManager	订阅信息管理器
SubscribeInfoManagerAccessor
SubscriberInfo	订阅者信息
TopicPartitionRegInfo	订阅消息的注册信息

枚举摘要

HashAlgorithm	Known hashing algorithms for locating a server for a key.
LoadBalanceStrategy.Type