gwenshap opened a new pull request #9815: URL: https://github.com/apache/kafka/pull/9815
Changes: * Passing the latches into the consumer/producer wrappers seemed a bit unclean. I removed the latches and used futures to wait on producer/consumer execution. * Consumer that is part of the transaction should not auto-commit * Transactional producers don't need to set idempotency explicitly. ---------------------------------------------------------------- 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: [email protected]
