Commit offsets for a topic to Zookeeper
Commit offsets for a topic to Zookeeper
a OffsetCommitRequest object.
a OffsetCommitResponse object.
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 a set of messages from a topic.
Fetch a set of messages from a topic. This version of the fetch method takes the Scala version of a fetch request (i.e., FetchRequest and is intended for use with the FetchRequestBuilder.
specifies the topic name, topic partition, starting byte offset, maximum bytes to be fetched.
a set of fetched messages
Fetch offsets for a topic from Zookeeper
Fetch offsets for a topic from Zookeeper
a OffsetFetchRequest object.
a 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 OffsetRequest object.
a OffsetResponse object.
Fetch metadata for a sequence of topics.
Fetch metadata for a sequence of topics.
specifies the versionId, clientId, sequence of topics.
metadata for each topic in the request.
A consumer of kafka messages