spark stream上创建对象实例

kafkaStream.foreachRDD { rdd =>

rdd.foreachPartition { partition =>
//每次在这里创建一个kafka producer实例是不可取的
}
}

kafkaStream.foreachRDD { rdd =>

rdd.foreachPartition { partition =>

var database = new File(geodataPath)

val producer = getKafka(kafkaMetaDataBrokerList)
}
}

var kafkaProducer:Producer = null

def getKafka(kafkaMetaDataBrokerList:String) = {

if(kafkaProducer == null){
kafkaProducer = new Producer(kafkaMetaDataBrokerList);
}
kafkaProducer
}