@Override
    public synchronized void fatalError(KafkaException fatalException) {
        super.fatalError(fatalException);
        notifyAll();
    }
Wait for metadata update until the current version is larger than the last version we know of
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java