基於累加器實現定時消費Kafka後自動關閉的SparkStreaming

前文：java             實時Sparkstreaming將至少佔用2個core，當咱們對數據實時性要求不高時，可採起定時消費Kafka數據，這裏就要思考如何將消費完Kafka的實時程序關閉。bash 1、spa 一、原始實時代碼code ssc.start() ssc.awaitTermination() 注：這種方式將一直佔用core數，對於實時性不高的程序將會形成極大資

>>阅读原文<<