HiI am reading the kafka source code now. I have a problem about the
"BufferPool" class int the file
"org.apache.kafka.clients.producer.internals.BufferPool.java"the source code is
like this:
this.lock.lock(); try { // check if we have a free buffer of
the right size pooled if (size == poolableSize &&
!this.free.isEmpty()) return this.free.pollFirst();
the function returns a free memory without "unlock" operation?
I haven't found any issue about this in the jira web site. is it a mistake? or
Do I misunderstand the code?
I'm sorry ,my english is poor. look forward to your reply.
