接口的使用
org.joyqueue.client.internal.consumer.callback.PartitionFetchListener

使用PartitionFetchListener的程序包

程序包	说明
org.joyqueue.client.internal.consumer
org.joyqueue.client.internal.consumer.support

org.joyqueue.client.internal.consumer中PartitionFetchListener的使用

参数类型为PartitionFetchListener的org.joyqueue.client.internal.consumer中的方法

限定符和类型	方法和说明
void	MessageFetcher.fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout, PartitionFetchListener listener)
void	MessageFetcher.fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout, PartitionFetchListener listener)

org.joyqueue.client.internal.consumer.support中PartitionFetchListener的使用

参数类型为PartitionFetchListener的org.joyqueue.client.internal.consumer.support中的方法

限定符和类型	方法和说明
void	MessageFetcherWrapper.fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout, PartitionFetchListener listener)
void	DefaultMessageFetcher.fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, int count, long timeout, PartitionFetchListener listener)
void	MessageFetcherWrapper.fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout, PartitionFetchListener listener)
void	DefaultMessageFetcher.fetchPartitionAsync(BrokerNode brokerNode, String topic, String app, short partition, long index, int count, long timeout, PartitionFetchListener listener)