如何使用带有特定分区的Apache Flink将数据作为键/值发送到Kafka

import org.apache.flink.api.common.serialization.SimpleStringSchema;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer;

public class FlinkToKafka {
    public static void main(String[] args) throws Exception {
        // 创建Flink执行环境
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 创建数据流
        DataStream<String> stream = env.fromElements(
            "key1,value1",
            "key2,value2",
            "key3,value3"
        );

        // 配置Kafka生产者
        FlinkKafkaProducer<String> kafkaProducer = new FlinkKafkaProducer<>(
            "your-kafka-topic",          // 目标Kafka主题
            new SimpleStringSchema(),     // 序列化方案
            properties                   // Kafka配置属性
        );

        // 将数据流发送到Kafka
        stream.addSink(kafkaProducer);

        // 执行Flink作业
        env.execute("Flink to Kafka Example");
    }
}