Skip to content

MINOR: use classic consumer with ZK mode for DeleteOffsetsConsumerGroupCommandIntegrationTest#15872

Merged
chia7712 merged 1 commit into
apache:trunkfrom
FrankYang0529:minor-use-zk-with-classic-consumer-for-DeleteOffsetsConsumerGroupCommandIntegrationTest
May 9, 2024
Merged

MINOR: use classic consumer with ZK mode for DeleteOffsetsConsumerGroupCommandIntegrationTest#15872
chia7712 merged 1 commit into
apache:trunkfrom
FrankYang0529:minor-use-zk-with-classic-consumer-for-DeleteOffsetsConsumerGroupCommandIntegrationTest

Conversation

@FrankYang0529
Copy link
Copy Markdown
Member

Ref: #15766 (comment)

Add ZK mode with classic consumer back to DeleteOffsetsConsumerGroupCommandIntegrationTest.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@chia7712
Copy link
Copy Markdown
Member

chia7712 commented May 6, 2024

Maybe we should merge DeleteOffsetsConsumerGroupCommandIntegrationTest and DeleteConsumerGroupsTest. They are used to test delete-related commands.

@ClusterTest
@ClusterTemplate("generator")
public void testDeleteOffsetsOfStableConsumerGroupWithTopicPartition() {
for (Map<String, Object> consumerConfig: consumerConfigs) {
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

consumerConfigs need to be rewritten by ClusterInstance#supportedGroupProtocols

see https://github.com/apache/kafka/pull/15766/files#r1590222192

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Updated it. Thanks.

@FrankYang0529 FrankYang0529 force-pushed the minor-use-zk-with-classic-consumer-for-DeleteOffsetsConsumerGroupCommandIntegrationTest branch from 4bd4005 to c8a2e3f Compare May 7, 2024 15:13

@ClusterTest
private static void generator(ClusterGenerator clusterGenerator) {
Map<String, String> serverProperties = new HashMap<>();
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please use ConsumerGroupCommandTestUtils#generator

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Updated it. Thanks.

…upCommandIntegrationTest

Signed-off-by: PoAn Yang <payang@apache.org>
@FrankYang0529 FrankYang0529 force-pushed the minor-use-zk-with-classic-consumer-for-DeleteOffsetsConsumerGroupCommandIntegrationTest branch from c8a2e3f to 68ebedb Compare May 8, 2024 13:54
Copy link
Copy Markdown
Member

@chia7712 chia7712 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@chia7712 chia7712 merged commit 397d58b into apache:trunk May 9, 2024
@FrankYang0529 FrankYang0529 deleted the minor-use-zk-with-classic-consumer-for-DeleteOffsetsConsumerGroupCommandIntegrationTest branch May 9, 2024 15:57
rreddy-22 pushed a commit to rreddy-22/kafka-rreddy that referenced this pull request May 9, 2024
…upCommandIntegrationTest (apache#15872)

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
gongxuanzhang pushed a commit to gongxuanzhang/kafka that referenced this pull request Jun 12, 2024
…upCommandIntegrationTest (apache#15872)

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants