org.apache.twill.kafka.client

Interface FetchedMessage

public interface FetchedMessage

Method Summary

Modifier and Type	Method and Description
long	getNextOffset() Returns the offset for the next message to be read.
long	getOffset() Returns the offset for the current message.
ByteBuffer	getPayload()
TopicPartition	getTopicPartition()

Method Detail

getTopicPartition

TopicPartition getTopicPartition()

getPayload

ByteBuffer getPayload()

getOffset

long getOffset()

Returns the offset for the current message.

getNextOffset

long getNextOffset()

Returns the offset for the next message to be read.