aliehsaeedii commented on code in PR #20157:
URL: https://github.com/apache/kafka/pull/20157#discussion_r2204893490
##########
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java:
##########
@@ -496,7 +496,8 @@ Map<String, Map<TopicPartition, OffsetAndMetadata>>
resetOffsets() {
if (e.getCause() instanceof
UnknownTopicOrPartitionException) {
printError("Deleting internal
topics for group '" + groupId + "' failed because the topics do not exist.",
Optional.empty());
} else if (e.getCause() instanceof
UnsupportedVersionException) {
- printError("Deleting internal
topics is not supported by the broker version. " +
+ printError("Deleting internal
topics is not supported by the broker version.\n" +
+ "Topics: (" +
String.join(",", internalTopics) + ").\n" +
Review Comment:
Add `Internal` here as well?! Like the other error message
--
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: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
