gabriellefu opened a new pull request, #22788: URL: https://github.com/apache/kafka/pull/22788
Changes
Moved the following types from
org.apache.kafka.coordinator.group.streams.assignor (internal) to the new
public package
org.apache.kafka.coordinator.group.api.assignor.streams:
- TaskAssignor (entry point)
- GroupSpec, MemberSubscription, TopologyDescriber (assignor inputs)
- GroupAssignment, MemberAssignment (assignor outputs)
- TaskId
- TaskAssignorException
Additional changes:
- Renamed AssignmentMemberSpec → MemberSubscription to align with the
public API naming in the KIP.
- Annotated all promoted types with @InterfaceAudience.Public and
@InterfaceStability.Evolving, and added package-info.java for the new package.
- Repointed all internal call sites (GroupMetadataManager,
TargetAssignmentBuilder, tests, jmh-benchmarks) to the new package.
- Implementation classes (StickyTaskAssignor, GroupSpecImpl, MockAssignor,
ProcessState) intentionally remain internal in group-coordinator.
The promoted types depend only on clients and JDK types, so no internal
group-coordinator types leak into the public API surface.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
