diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java b/clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java index 22d747265d618..990dc2c692f3c 100644 --- a/clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java +++ b/clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java @@ -168,15 +168,7 @@ public ByteBuffer allocate(int size, long maxTimeToBlockMs) throws InterruptedEx } } } finally { - // signal any additional waiters if there is more memory left - // over for them - try { - if (!(this.nonPooledAvailableMemory == 0 && this.free.isEmpty()) && !this.waiters.isEmpty()) - this.waiters.peekFirst().signal(); - } finally { - // Another finally... otherwise find bugs complains - lock.unlock(); - } + lock.unlock(); } if (buffer == null)