Skip to content

Conversation

@AnGg98
Copy link
Contributor

@AnGg98 AnGg98 commented Dec 2, 2025

This PR adds a helper method to create topics using the raw admin client
in GroupCoordinatorBaseRequestTest. It also updates related tests to
use the existing createOffsetsTopic helper instead of manually
duplicating topic-creation logic in multiple places. No functional
changes to test behavior.

Reviewers: David Jacot djacot@confluent.io

@github-actions github-actions bot added triage PRs from the community core Kafka Broker tests Test fixes (including flaky tests) labels Dec 2, 2025
}
}

protected def createTopicWithAdminRaw(
Copy link
Member

Choose a reason for hiding this comment

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

We already have createTopic in this class. I wonder whether we could unify both. Have you checked by chance?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

We could use createTopic as well I believe, but that method waits for the metadata to propagate to all brokers. The helper we are introducing here (extracted from existing test usage) simply creates the topic and returns without waiting.

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Using createTopic now

// in this test because it does not use FindCoordinator API.
createOffsetsTopic()

val admin = cluster.admin()
Copy link
Member

Choose a reason for hiding this comment

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

Do we still need it?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Ah, I missed removing it earlier. I have removed it now.

@dajac dajac added ci-approved and removed triage PRs from the community labels Dec 2, 2025
Copy link
Member

@dajac dajac left a comment

Choose a reason for hiding this comment

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

lgtm, thanks.

@dajac dajac merged commit 4e075e9 into apache:trunk Dec 2, 2025
25 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

ci-approved core Kafka Broker tests Test fixes (including flaky tests)

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants