Hi all, During implementation, we identified a few issues and made the following updates to the KIP:
1. TaskId is no longer part of the public API I removed TaskId from the public assignor interfaces. It still exists as an internal record (o.a.k.coordinator.group.streams.assignor.TaskId) used by the sticky assignor implementation, but it no longer appears in any public-facing type. This keeps the public surface smaller and avoids committing to TaskId as a stable API. 2. Offsets are now Map<String, Map<Integer, Long>>; Following the removal of TaskId, taskOffsets() and taskEndOffsets() on MemberAssignmentState are now keyed by subtopology ID (outer map) → partition (inner map) → offset, rather than by TaskId. 3. Package rename I also moved the public API package from o.a.k.coordinator.group.api.assignor.streams to o.a.k.coordinator.group.api.streams.assignor, so the Streams assignor API now lives under a Streams namespace. Please let me know if you have any other concerns. Thanks! Best, Gabriella On Thu, Jul 16, 2026 at 4:58 PM Gabriella Fu <[email protected]> wrote: > Hi all, > I have update my kip with the following change, > 1) TaskId is now defined in the Public Interfaces section. > It was previously referenced by MemberAssignmentState (Map<TaskId, Long>) > but never actually defined. It is now a public interface, with the concrete > implementation kept internal > 2) GroupAssignment is now specified as a record rather than a class. > > > It's an output/return type, and the record exposes the same public > surface (canonical constructor + members() accessor) with less > boilerplate. > > Best, > Gabriella > > On Wed, Jul 8, 2026 at 7:55 PM Ziyun Fu (Jira) <[email protected]> wrote: > >> >> [ >> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/KAFKA-20789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel__;!!Ayb5sqE7!vqGmtxpCDE5IBAVEDrYw_5yS2YmOkOm3fXl6dtfRqDal9CeGOq2qGUTVVJxcEEDRMYnXFg1hgvbH$ >> ] >> >> Ziyun Fu resolved KAFKA-20789. >> ------------------------------ >> Resolution: Duplicate >> >> > KIP-1357: Promote streams assignor API to public module >> > ------------------------------------------------------- >> > >> > Key: KAFKA-20789 >> > URL: >> https://urldefense.com/v3/__https://issues.apache.org/jira/browse/KAFKA-20789__;!!Ayb5sqE7!vqGmtxpCDE5IBAVEDrYw_5yS2YmOkOm3fXl6dtfRqDal9CeGOq2qGUTVVJxcEEDRMYnXFviNXAVR$ >> > Project: Kafka >> > Issue Type: Improvement >> > Reporter: Ziyun Fu >> > Assignee: Ziyun Fu >> > Priority: Major >> > >> > reshape the public api as described in KIP1357 >> >> >> >> -- >> This message was sent by Atlassian Jira >> (v8.20.10#820010) >> >
