Commit offsets for a topic Version 0 of the request will commit offsets to Zookeeper and version 1 and above will commit offsets to Kafka.
Commit offsets for a topic Version 0 of the request will commit offsets to Zookeeper and version 1 and above will commit offsets to Kafka.
a kafka.api.OffsetCommitRequest object.
a kafka.api.OffsetCommitResponse object.
Unblock thread by closing channel and triggering AsynchronousCloseException if a read operation is in progress.
Unblock thread by closing channel and triggering AsynchronousCloseException if a read operation is in progress.
This handles a bug found in Java 1.7 and below, where interrupting a thread can not correctly unblock the thread from waiting on ReadableByteChannel.read().
Get the earliest or latest offset of a given topic, partition.
Get the earliest or latest offset of a given topic, partition.
Topic and partition of which the offset is needed.
A value to indicate earliest or latest offset.
Id of the consumer which could be a consumer client, SimpleConsumerShell or a follower broker.
Requested offset.
Fetch a set of messages from a topic.
Fetch a set of messages from a topic.
specifies the topic name, topic partition, starting byte offset, maximum bytes to be fetched.
a set of fetched messages
Fetch offsets for a topic Version 0 of the request will fetch offsets from Zookeeper and version 1 and above will fetch offsets from Kafka.
Fetch offsets for a topic Version 0 of the request will fetch offsets from Zookeeper and version 1 and above will fetch offsets from Kafka.
a kafka.api.OffsetFetchRequest object.
a kafka.api.OffsetFetchResponse object.
Get a list of valid offsets (up to maxSize) before the given time.
Get a list of valid offsets (up to maxSize) before the given time.
a kafka.api.OffsetRequest object.
a kafka.api.OffsetResponse object.
A consumer of kafka messages