@Override
    public synchronized void close() {
        super.close();
        notifyAll();
    }
Close this instance and notify any awaiting threads.
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java