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

使用 ConsumerConfig 的软件包

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

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

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

protected void	MetaMessageSessionFactory.checkConsumerConfig(ConsumerConfig consumerConfig)
MessageConsumer	MetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig)
MessageConsumer	MessageSessionFactory.createConsumer(ConsumerConfig consumerConfig) 创建消息消费者，默认将offset存储在zk
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)
protected LoadBalanceStrategy	MetaMessageSessionFactory.createLoadBalanceStrategy(ConsumerConfig consumerConfig)

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

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

ConsumerConfig	SimpleMessageConsumer.getConsumerConfig()
ConsumerConfig	MessageConsumer.getConsumerConfig() 返回消费者配置
ConsumerConfig	InnerConsumer.getConsumerConfig()

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

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

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

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

SimpleFetchManager(ConsumerConfig consumerConfig, InnerConsumer consumer)

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

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

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

MessageConsumer	MetaBroadcastMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig)
MessageConsumer	BroadcastMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig) 创建广播方式接收的消息消费者，offset将存储在本地
MessageConsumer	ExtMetaMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType)
MessageConsumer	ExtMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType) 创建广播消费者
protected MessageConsumer	MetaBroadcastMessageSessionFactory.createBroadcastConsumer(ConsumerConfig consumerConfig, RecoverManager recoverManager)
MessageConsumer	OrderedMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig)
MessageConsumer	ExtMetaMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType recoverType)
MessageConsumer	ExtMessageSessionFactory.createConsumer(ConsumerConfig consumerConfig, ConsumerRecoverType RecoverType) 创建消费者
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.client.extension.spring 中 ConsumerConfig 的使用

返回 ConsumerConfig 的 com.taobao.metamorphosis.client.extension.spring 中的方法

ConsumerConfig

MetaqTopic.getConsumerConfig()

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

void	MetaqTopic.setConsumerConfig(ConsumerConfig consumerConfig)

参数类型为 ConsumerConfig 的 com.taobao.metamorphosis.client.extension.spring 中的构造方法

MetaqTopic(String topic, int maxBufferSize, ConsumerConfig consumerConfig)

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

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

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

com.taobao.metamorphosis.storm.spout 中 ConsumerConfig 的使用

参数类型为 ConsumerConfig 的 com.taobao.metamorphosis.storm.spout 中的构造方法

MetaSpout(MetaClientConfig metaClientConfig, ConsumerConfig consumerConfig, backtype.storm.spout.Scheme scheme)