[
https://issues.apache.org/jira/browse/KAFKA-5235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-5235:
--------------------------------
Description: Currently, GetOffsetShell only allows fetching the offsets of
a single topic with an optional list of which partitions to describe. Besides
that, it does not allow consumer properties to be overridden. The tool does not
have a dedicated script under bin either. (was: 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.)
> 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
> Assignee: Daniel Urban
> Priority: Major
> Labels: kip, tool
> Original Estimate: 168h
> Remaining Estimate: 168h
>
> Currently, GetOffsetShell only allows fetching the offsets of a single topic
> with an optional list of which partitions to describe. Besides that, it does
> not allow consumer properties to be overridden. The tool does not have a
> dedicated script under bin either.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
