Indeed it changes the behavior of how we close the producer as it won't be a force close after the refactor, however I don't think it changes the behavior of the test itself. Since we're not setting any response on the mock client, the initTransaction should timeout regardless of how do we close the connection at the end. @huxihx as you're the author of the original code, would you please help us whether this change is correct or are there any details I'm missing?
[ Full content available at: https://github.com/apache/kafka/pull/5548 ] This message was relayed via gitbox.apache.org for [email protected]
