| 返回 MessageIterator 的 com.taobao.metamorphosis.client.consumer 中的方法 |
MessageIterator |
SimpleMessageConsumer.fetch(FetchRequest fetchRequest,
long timeout,
TimeUnit timeUnit)
|
MessageIterator |
InnerConsumer.fetch(FetchRequest fetchRequest,
long timeout,
TimeUnit timeUnit)
抓取消息 |
MessageIterator |
SimpleMessageConsumer.get(String topic,
Partition partition,
long offset,
int maxSize)
|
MessageIterator |
MessageConsumer.get(String topic,
Partition partition,
long offset,
int maxSize)
获取指定topic和分区下面的消息，默认超时10秒 |
MessageIterator |
SimpleMessageConsumer.get(String topic,
Partition partition,
long offset,
int maxSize,
long timeout,
TimeUnit timeUnit)
|
MessageIterator |
MessageConsumer.get(String topic,
Partition partition,
long offset,
int maxSize,
long timeout,
TimeUnit timeUnit)
获取指定topic和分区下面的消息，在指定时间内没有返回则抛出异常 |