软件包 com.taobao.metamorphosis.client.consumer
的使用

使用 com.taobao.metamorphosis.client.consumer 的软件包

com.taobao.metamorphosis.client
com.taobao.metamorphosis.client.consumer
com.taobao.metamorphosis.client.consumer.storage
com.taobao.metamorphosis.client.extension
com.taobao.metamorphosis.client.extension.consumer
com.taobao.metamorphosis.client.extension.spring
com.taobao.metamorphosis.metaslave
com.taobao.metamorphosis.storm.spout

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

ConsumerConfig
消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。

ConsumerZooKeeper
Consumer与Zookeeper交互

LoadBalanceStrategy
Consumer的balance策略

MessageConsumer
消息消费者，线程安全，推荐复用

RecoverManager
消费端的Recover管理器

SubscribeInfoManager
订阅信息管理器

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

AbstractRecoverManager

ConsumerConfig
消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。

ConsumerZooKeeper
Consumer与Zookeeper交互

ConsumerZooKeeper.ZKLoadRebalanceListener
Consumer load balance listener for zookeeper.

FetchManager
Fetch请求管理器接口

FetchRequest
一次获取请求

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

InnerConsumer
不对外提供的consumer接口，用于提供给Fetch使用

LoadBalanceStrategy
Consumer的balance策略

LoadBalanceStrategy.Type

MessageConsumer
消息消费者，线程安全，推荐复用

MessageIdCache
Message id cache to prevent duplicated messages for the same consumer group.

MessageListener
异步消息监听器

RecoverManager
消费端的Recover管理器

RejectConsumptionHandler
Created with IntelliJ IDEA.

SubscribeInfoManager
订阅信息管理器

SubscriberInfo
订阅者信息

TopicPartitionRegInfo
订阅消息的注册信息

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

TopicPartitionRegInfo
订阅消息的注册信息

com.taobao.metamorphosis.client.extension 使用的 com.taobao.metamorphosis.client.consumer 中的类

ConsumerConfig
消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。

MessageConsumer
消息消费者，线程安全，推荐复用

RecoverManager
消费端的Recover管理器

com.taobao.metamorphosis.client.extension.consumer 使用的 com.taobao.metamorphosis.client.consumer 中的类

AbstractRecoverManager

RecoverManager
消费端的Recover管理器

com.taobao.metamorphosis.client.extension.spring 使用的 com.taobao.metamorphosis.client.consumer 中的类

ConsumerConfig
消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。

LoadBalanceStrategy.Type

MessageConsumer
消息消费者，线程安全，推荐复用

MessageListener
异步消息监听器

RejectConsumptionHandler
Created with IntelliJ IDEA.

com.taobao.metamorphosis.metaslave 使用的 com.taobao.metamorphosis.client.consumer 中的类

ConsumerConfig
消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。

ConsumerZooKeeper
Consumer与Zookeeper交互

FetchManager
Fetch请求管理器接口

LoadBalanceStrategy
Consumer的balance策略

MessageListener
异步消息监听器

SubscriberInfo
订阅者信息

TopicPartitionRegInfo
订阅消息的注册信息

com.taobao.metamorphosis.storm.spout 使用的 com.taobao.metamorphosis.client.consumer 中的类

ConsumerConfig
消费者配置，主要配置选项如下： group:分组名称，必须，表示该消费者所在分组，同一分组的消费者正常情况下不会接收重复消息，共同消费某一topic consumerId: 消费者id，用于唯一标识一个消费者，可不设置，系统会根据分组名称自动生成 commitOffsetPeriodInMills: 保存offset的时间间隔，默认5秒，单位毫秒 fetchTimeoutInMills: 同步获取消息的默认超时时间，默认10秒，单位毫秒 maxDelayFetchTimeInMills: 当获取消息失败的时候（包括get miss或者任何异常情况)会延迟获取，此值设置最大的延迟时间，单位毫秒 fetchRunnerCount: 获取消息的线程数，默认cpu个。