Arseniy Tashoyan created KAFKA-5235:
---------------------------------------
Summary: GetOffsetShell: retrieve offsets for all given topics and
partitions with single request to the broker
Key: KAFKA-5235
URL: https://issues.apache.org/jira/browse/KAFKA-5235
Project: Kafka
Issue Type: Improvement
Components: tools
Reporter: Arseniy Tashoyan
Fix For: 0.11.0.0
GetOffsetShell is implemented on old SimpleConsumer. It needs Zookeeper to
retrieve metadata about topics and partitions. At present, GetOffsetShell does
the following:
- get metadata from Zookeeper
- iterate over partitions
- for each partition, connect to its leader broker and request offsets
Instead, GetOffsetShell can use new KafkaConsumer and retrieve offsets by means
of endOffsets(), beginningOffsets() and offsetsForTimes() methods. One request
is sufficient for all topics and partitions.
As far as GetOffsetShell is re-implemented with new KafkaConsumer API, it will
not depend on obsolete API: SimpleConsumer, old producer API.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
