org.joyqueue.client.internal.consumer.callback

接口 PartitionConsumerListener

public interface PartitionConsumerListener

BatchPartitionFetchListener author: gaohaoxiang date: 2018/12/10

方法概要

限定符和类型	方法和说明
void	onException(String topic, short partition, long index, Throwable cause)
void	onMessage(FetchMessageData fetchMessageData)

方法详细资料

onMessage

void onMessage(FetchMessageData fetchMessageData)

onException

void onException(String topic,
                 short partition,
                 long index,
                 Throwable cause)