chia7712 commented on a change in pull request #9991:
URL: https://github.com/apache/kafka/pull/9991#discussion_r566241334
##########
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java
##########
@@ -644,11 +644,7 @@ private UnsentRequests() {
public void put(Node node, ClientRequest request) {
// the lock protects the put from a concurrent removal of the
queue for the node
synchronized (unsent) {
- ConcurrentLinkedQueue<ClientRequest> requests =
unsent.get(node);
- if (requests == null) {
- requests = new ConcurrentLinkedQueue<>();
- unsent.put(node, requests);
Review comment:
my bad. please ignore above comment :(
----------------------------------------------------------------
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:
us...@infra.apache.org
