MINOR: kafka-stream-groups.sh should fail quickly if the partition leader is unavailable

[JimmyWang6]

Refer to: #20168 and
#20235 This PR applies
the same partition leader check for StreamsGroupCommand as
ShareGroupCommand and ConsumerGroupCommand to aviod the command
execution timeout.

Reviewers: Lucas Brutschy lucasbru@apache.org

[TaiJuWu]

Could you add test case for this behaviour?

[JimmyWang6]

Could you add test case for this behaviour?

Sure, thanks for your comments!

[github-actions]

A label of 'needs-attention' was automatically added to this PR in order to raise the
attention of the committers. Once this issue has been triaged, the triage label
should be removed to prevent this automation from happening again.

[JimmyWang6]

@TaiJuWu Sorry for the late response, I have updated the PR, please take a look when available, thanks~

[github-actions]

A label of 'needs-attention' was automatically added to this PR in order to raise the
attention of the committers. Once this issue has been triaged, the triage label
should be removed to prevent this automation from happening again.

[JimmyWang6]

Hi @aliehsaeedii @chia7712 @lucasbru , I was wondering if you could take a look at it when you get a chance. Thanks~

[github-actions]

A label of 'needs-attention' was automatically added to this PR in order to raise the
attention of the committers. Once this issue has been triaged, the triage label
should be removed to prevent this automation from happening again.

[lucasbru]

@JimmyWang6 Thanks for the PR! There are test failures. Could you take a look?

[Copilot]

Pull Request Overview

This PR adds partition leader validation to the StreamsGroupCommand to avoid command execution timeouts when partition leaders are unavailable, aligning with similar checks already implemented in ShareGroupCommand and ConsumerGroupCommand.

• Adds partition validation check in getPartitionsToReset() method
• Includes test case for handling non-existent partitions
• Fixes a minor typo in ShareGroupCommandTest

Reviewed Changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated no comments.

File	Description
tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java	Adds partition leader validation call to prevent timeouts
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandTest.java	Adds test case and imports for partition validation scenario
tools/src/test/java/org/apache/kafka/tools/consumer/group/ShareGroupCommandTest.java	Fixes typo in test method name

---

_{Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.}

[JimmyWang6]

@lucasbru Thanks for your reply! I haved fixed the failure test, PTAL.

[lucasbru]

LGTM, thanks!