如果 dStream 包含要发送到 Kafka 的数据:

if dStream contains data that you want to send to Kafka:

dStream.foreachRDD(rdd -> {
    rdd.foreachPartition(iter ->{
        Producer producer = createKafkaProducer();  
        while (iter.hasNext()){
               sendToKafka(producer, iter.next())
        }
    }

});

因此，您为每个 RDD 分区创建一个生产者.

So, you create one producer per each RDD partition.