ji-seung-ryu opened a new pull request, #19872: URL: https://github.com/apache/kafka/pull/19872
Hi, I've created pull request. jira: [19328](https://issues.apache.org/jira/browse/KAFKA-19328) problem: 1. doAnswer chaining works as intended only when calls are made sequentially. In a multithreaded environment, its behavior is unpredictable. 2. errors in a thread can be swallowed, not seen in main thread. 3. 5 doAnswer chain is not enough for 100 threads. The last chain is returned for most cases. 4. I am not sure if this is true, but nextFetchOffset seems to be called out of doAnswer chain, so the last values (25, 5, 26, 16) was found in doAsnwer chain. solution: Delete doAnswer chain so that above three problems automatically disappear. -- 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