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

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

com.taobao.metamorphosis.client.consumerFetchRequest 的使用
 

参数类型为 FetchRequestcom.taobao.metamorphosis.client.consumer 中的方法
 void SimpleFetchManager.addFetchRequest(FetchRequest request)
           
 void FetchManager.addFetchRequest(FetchRequest request)
          添加fetch请求
 MessageIterator SimpleMessageConsumer.fetch(FetchRequest fetchRequest, long timeout, TimeUnit timeUnit)
           
 MessageIterator InnerConsumer.fetch(FetchRequest fetchRequest, long timeout, TimeUnit timeUnit)
          抓取消息
 long SimpleMessageConsumer.offset(FetchRequest fetchRequest)
           
 long InnerConsumer.offset(FetchRequest fetchRequest)
          查询offset
 



Copyright © 2010–2013. All rights reserved.