ableegoldman opened a new pull request, #16349: URL: https://github.com/apache/kafka/pull/16349
End-to-end integration test for the new TaskAssignor interface and public config. This test builds on top of the existing TaskAssignorIntegrationTest which simply checked the assignor configuration for the legacy task assignor and the old `internal.task.assignor.class` config. We extend it in a few ways: 1. Add some missing configs (basically all the rack-aware stuff) to the validation of the assignor configuration 2. Add two new tests which check the assignor configuration when plugging in a TaskAssignor via the new public `task.assignor.class` config in KIP-924: a simple test that verifies you can use the new StickyTaskAssignor and a more complex test that does some additional verification via a custom assignor implementation 3. The custom assignor test covers all new features of the KIP-924 TaskAssignor, such as the ability to configure it, the post-assignment callback, and the ability to assign only a subset of tasks or even no tasks at all to a client -- 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]
