sparkstreaming寫入kafka的性能優化

在實際的項目中,有時候咱們須要把一些數據實時的寫回到kafka中去,通常的話咱們是這樣寫的,以下:javascript kafkaStreams.foreachRDD(rdd => { if (!rdd.isEmpty()) { rdd.foreachPartition(pr => { val properties = new Properties(

>>阅读原文<<