[KAFKA-6321] ConsumerGroupCommand should use the new consumer to query the log end offsets.

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.1.0
• Component/s: tools
• Assignee: Vahid Hashemian
• Reporter: Jiangjie Qin
• Created: 06/Dec/17 22:00
• Updated: 26/Jan/18 22:29
• Resolved: 26/Jan/18 22:29

Description

Currently the ConsumerGroupCommand is querying the log end offsets one partition at a time. It should switch to use Consumer.endOffsets().

Issue Links

• relates to: KAFKA-6489 Fetcher.retrieveOffsetsByTimes() should add all the topics to the metadata refresh topics set.
• links to: GitHub Pull Request #4344
• links to: GitHub Pull Request #4344