Commit offsets for a topic
Commit offsets for a topic
a kafka.api.OffsetCommitRequest object.
a kafka.api.OffsetCommitResponse object.
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
Fetch offsets for a topic
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