kirktrue opened a new pull request, #14406: URL: https://github.com/apache/kafka/pull/14406
Changes: 1. Introduces `FetchRequestManager` that implements the `RequestManager` API for fetching messages from brokers. Unlike `Fetcher`, record decompression and deserialization is performed on the application thread inside `CompletedFetch`. 2. Restructured the code so that objects owned by the background thread are not instantiated until the background thread runs (via `Supplier`) to ensure that there are no references available to the application thread. 3. Ensuring resources are properly using `Closeable` and using `IdempotentCloser` to ensure they're only closed once. 4. Introduces `ConsumerTestBuilder` to reduce a lot of inconsistency in the way the objects were built up for tests. -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
