mirror of https://github.com/apache/kafka.git
31545eb614
* Merging the Refactory to add standby tasks heartbeat response added test Add stability check and refactor partition assignments Introduces a `membersStable` method in `StreamsGroup` to ensure group members are in a stable state before partition assignments. Refactors `EndpointToPartitionsManager` to streamline input topic handling and updates related tests for clarity and correctness. Adds integration test for validating partition assignment logic with multiple configurations. * Refactor IQv2 metadata handling and endpoint partition mapping. Streamlined metadata validation logic in IQv2 integration tests and removed redundant code. Simplified `maybeBuildEndpointToPartitions` by eliminating unnecessary stability checks, improving clarity and maintainability of endpoint-to-partition mapping. * Remove unused `membersStable` method from StreamsGroup * Refactor and enhance IQv2 test metadata validation. Replaced redundant variable names and improved metadata handling for active and standby tasks in the IQv2 test. Added validations for state store names using `EXPECTED_STORE_NAME` and organized metadata assertions to enhance clarity and testing coverage. These changes improve maintainability and ensure better validation of stream metadata. * Add inspection of standby topics |
||
|---|---|---|
| .. | ||
| src | ||
| .gitignore | ||