@Override
  public void send(LogData<T> logData) throws Exception {
    checkErroneous();
    byte[] message = logDataJsonSerialization.serialize(logData);
    int partition = mixedFormatLogPartitioner.partition(logData, partitions);
    ProducerRecord<byte[], byte[]> producerRecord =
        new ProducerRecord<>(topic, partition, null, null, message);
    producer.send(producerRecord, callback);
  }
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