rondagostino opened a new pull request #10013: URL: https://github.com/apache/kafka/pull/10013
`TransactionStateManager` currently uses ZooKeeper to obtain any non-default value for the `__transaction_state` partition count. ZooKeeper will not be available when the broker uses a Raft-based metadata quorum. This PR removes the hard dependency on ZooKeeper by allowing a function returning an `Int` to be provided instead. Providing a ZooKeeper client is still supported in `apply()` methods, but they transparently wrap the client with a function and pass that function instead. Existing tests are sufficient to detect bugs and regressions. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
