@Override
  public Producer<T> createProducer(
      Properties producerConfig,
      String topic,
      LogDataJsonSerialization<T> logDataJsonSerialization,
      ShuffleHelper helper) {
    checkNotNull(topic);
    return new HiddenKafkaProducer<>(
        producerConfig, topic, logDataJsonSerialization, new MixedFormatLogPartitioner<>(helper));
  }
A factory creates kafka log queue producers or consumers.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/write/hidden/kafka/HiddenKafkaFactory.java