mirror of
https://github.com/apache/kafka.git
synced 2026-10-28 08:24:58 +08:00
Follow-up to #23165. Test-only change. - `testStreamsGroupEpochDoesNotIncreaseWhenEveryAssignmentConfigIsAtItsDefault` now starts the group with non-default assignment configs, so it fails if replaying a record without configs does not reset them to the defaults. - Add `testStreamsGroupEpochIncreasesWhenAnAssignmentConfigIsNotAtItsDefault`: after the same replay, a group with `num.standby.replicas=2` still bumps the group epoch, since the replayed defaults differ from the current configs. - Add `AssignmentConfigsImplTest` cases for `fromRecord` with an empty list and with an unknown key. - Use `AssignmentConfigsImpl.DEFAULT` instead of `new AssignmentConfigsImpl(0, List.of())` in `GroupMetadataManagerTest`. Reviewers: Lucas Brutschy <lbrutschy@confluent.io>