Skip to content

KAFKA-20790: add AssignmentConfigs interface - #23092

Open
gabriellefu wants to merge 7 commits into
apache:trunkfrom
gabriellefu:assignmentconfig
Open

KAFKA-20790: add AssignmentConfigs interface#23092
gabriellefu wants to merge 7 commits into
apache:trunkfrom
gabriellefu:assignmentconfig

Conversation

@gabriellefu

@gabriellefu gabriellefu commented Aug 5, 2026

Copy link
Copy Markdown
Contributor

Adding AssignmentConfigs a public api for kip1357

Reviewers: Sean Quah squah@confluent.io

/**
* Converts the raw assignment configs computed for the group into the typed configs passed to the assignor.
*/
private static AssignmentConfigs toAssignmentConfigs(Map<String, String> assignmentConfigs) {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

A better place for this method could be as a constructor or static method on AssignmentConfigsImpl.

new GroupSpecImpl(
Map.of(),
new HashMap<>()
new AssignmentConfigsImpl(0, List.of())

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

It's going to be really annoying to update all these tests when we add new assignment configs.
We could consider declaring AssignmentConfigsImpl.DEFAULT or adding a constructor AssignmentConfigsImpl(Map<String, String>).

@github-actions github-actions Bot removed the triage PRs from the community label Aug 7, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants