Приложение Producer падает, когда кластер Kafka находится в автономном режиме

Question

Брокеры Kafka были перезапущены, и в результате приложение производителя потерпело крах.Сообщения отправляются в kafka в асинхронном режиме, что означает, что если брокер kafka находится в автономном режиме, приложение производителя не должно иметь никакого эффекта, поскольку блокирующие потоки не будут.Я хотел понять, почему приложение производителя сломалось.Есть предложения?

public void pushMessage(P partitionKey, M message, Consumer<Exception> exceptionHandler) {
   executorService.submit(() -> {
      // this.producer -> KafkaProducer<P, M> from the kafka lib
       producer.send(record, (metadata, exception) -> {
           if (exception != null && exceptionHandler != null) {
               exceptionHandler.accept(exception);
           }
       });
   });
}