protected FlinkKafkaInternalProducer<byte[], byte[]> createTransactionalProducer() {
    Properties transactionalProperties = new Properties();
    transactionalProperties.putAll(producerConfig);
    transactionalProperties.computeIfAbsent(
        TRANSACTIONAL_ID_CONFIG, o -> UUID.randomUUID().toString());
    return new FlinkKafkaInternalProducer<>(transactionalProperties);
  }
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