Kafkaflinkproducer似乎没有进行分区选择

如果使用Kafka Flink producer时发现没有进行分区选择，请确保以下几点：

1.在producer配置中设置要发送到的topic：

Properties props = new Properties();
props.setProperty("bootstrap.servers", "localhost:9092");
FlinkKafkaProducer<String> myProducer = new FlinkKafkaProducer<>(
  "my-topic",
  new SimpleStringSchema(),
  props);

2.如果要发送到特定的分区，请使用下面的代码：

myProducer.setWriteTimestampToKafka(true);
myProducer.setFlushOnCheckpoint(true);

// 模拟数据流
DataStream<String> stream = ...;

stream
  .map(new MyMapFunction())
  // 指定分区
  .addSink(myProducer)
  .setParallelism(2);

请注意，我的MapFunction必须实现KeyedFunction接口，并且必须在map之后使用keyBy操作。您还需要使用setWriteTimestampToKafka和setFlushOnCheckpoint方法，以确保消息正确写入Kafka。