Details
-
Sub-task
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
-
None
Description
As part of https://github.com/apache/kafka/commit/08aa33127a4254497456aa7a0c1646c7c38adf81 the finding of the coordinator was moved to the AddPartitionsToTxnManager. In the case of an error, we return the error on the wrapped callback.
This seemed to cause issues in the tests and we realized that executing the callback directly and not rescheduling it on the request channel seemed to resolve some issues.
One theory was that scheduling the callback before the request returned caused issues.
Ideally we wouldn't have this special handling. This ticket is to remove it.