protected void checkErroneous() throws FlinkKafkaException {
    Exception e = asyncException;
    if (e != null) {
      // prevent double throwing
      asyncException = null;
      throw new FlinkKafkaException(
          FlinkKafkaErrorCode.EXTERNAL_ERROR, "Failed to send data to Kafka: " + e.getMessage(), e);
    }
  }
Errors encountered in the async producer are stored here.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/hidden/kafka/HiddenKafkaProducer.java