kowshik opened a new pull request #10797: URL: https://github.com/apache/kafka/pull/10797
The trogdor `ConsumeBenchWorker` has a bug. If one of the consumption tasks completes executing successfully due to `maxMessages` being consumed, then, the consumption task notifies the `doneFuture` causing the entire `ConsumeBenchWorker` to halt. This becomes a problem when more than 1 consumption task is running in parallel, because the successful completion of 1 of the tasks shuts down the entire worker while the other tasks are still running. When the worker is shut down, it kills all the active consumption tasks, which is not the desired behavior. The fix is to not notify the `doneFuture` when 1 of the consumption tasks complete without error. Instead, we should defer the notification to the `CloseStatusUpdater` thread. -- 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
