flink讀取kafka數據並寫入HDFS

flink的官網對於寫入HDFS的例子比較簡單,很難跑起來,缺少更詳細的描述。 目標: 本地代碼flink streaming讀取遠程環境的kafka的數據,寫入遠程環境的HDFS中; 核心代碼: public static void main(String[] args) throws Exception { // set up the streaming execution
相關文章
相關標籤/搜索