@hachikuji I have documented the change and also added a test. I left `completedFetches` as a `ConcurrentLinkedQueue` since it is accessed by various methods and we should probably synchronize all the public methods in Fetcher if we want to change that. I think full synchronization is not necessary, but I am fine with doing that too to make it more obvious. Let me know what you think.
[ Full content available at: https://github.com/apache/kafka/pull/5495 ] This message was relayed via gitbox.apache.org for [email protected]
