OmniaGM commented on code in PR #16766:
URL: https://github.com/apache/kafka/pull/16766#discussion_r1705273716
##########
tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java:
##########
@@ -812,6 +813,9 @@ private Map<TopicPartition, LogOffsetResult>
getLogOffsets(Collection<TopicParti
: new Unknown()
));
} catch (InterruptedException | ExecutionException e) {
+ if
(e.getMessage().contains(UnknownTopicOrPartitionException.class.getCanonicalName()))
{
Review Comment:
Looking into reset offset test and apparently the script can also use
`--all-groups` and `--all-topics` which will hit the same issue if any single
group has a deleted topic in any of the combinations that has any of these
fields. I'll add tests to reset offset to catch this and fix it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
