FlinkKafkaProducer的重载构造函数

FlinkKafkaProducer 是 Apache Flink 中用于将 Flink 数据流写入 Kafka 的一个关键组件。FlinkKafkaProducer 提供了多个重载的构造函数，以适应不同的使用场景和配置需求。

以下是 FlinkKafkaProducer 的一些常见重载构造函数：

1. 基本构造函数：

public FlinkKafkaProducer(
    String topic,
    SerializationSchema<IN> serializationSchema,
    Properties producerConfig,
    FlinkKafkaPartitioner<IN> partitioner)

• topic: 目标 Kafka 主题。
• serializationSchema: 用于序列化 Flink 数据流元素的 SerializationSchema。
• producerConfig: Kafka 生产者的配置属性。
• partitioner: 用于确定数据应该发送到 Kafka 的哪个分区的 FlinkKafkaPartitioner。

1. 使用默认分区器的构造函数：

public FlinkKafkaProducer(
    String topic,
    SerializationSchema<IN> serializationSchema,
    Properties producerConfig)

这个构造函数与第一个构造函数类似，但它使用默认的分区器（通常是 FlinkKafkaPartitioner 的默认实现）。

1. 使用 FlinkKafkaProducer.Semantic 构造函数：

public FlinkKafkaProducer(
    String topic,
    SerializationSchema<IN> serializationSchema,
    Properties producerConfig,
    FlinkKirtual KafkaProducer.Semantic semantic)

• semantic: 定义了生产者语义的枚举值，例如 Semantic.EXACTLY_ONCE 或 Semantic.AT_LEAST_ONCE。这允许你控制写入 Kafka 时的数据一致性级别。

1. 使用 FlinkKafkaProducer.Semantic 和默认分区器的构造函数：

public FlinkKafkaProducer(
    String topic,
    SerializationTypeInformation<IN> typeInformation,
    Properties producerConfig,
    FlinkKafkaProducer.Semantics semantic)

这个构造函数与上一个类似，但它使用 SerializationTypeInformation 而不是 SerializationSchema，并且也使用默认的分区器。