org.apache.twill.kafka.client

Interface KafkaConsumer.MessageCallback

Enclosing interface:

KafkaConsumer

public static interface KafkaConsumer.MessageCallback

Callback for receiving new messages.

Method Summary

Modifier and Type	Method and Description
void	finished() Invoked when message consumption is stopped.
long	onReceived(Iterator<FetchedMessage> messages) Invoked when new messages is available.

Method Detail

onReceived

long onReceived(Iterator<FetchedMessage> messages)

Invoked when new messages is available.

Parameters:

messages - Iterator of new messages. The FetchedMessage instance maybe reused in the Iterator and across different invocation.

Returns:

The offset of the message to be fetched next.

finished

void finished()

Invoked when message consumption is stopped. When this method is invoked, no more onReceived(java.util.Iterator) will get triggered.