1,從spark的example中找到kafkawordcount.scala檔案複製到idea編輯器中,引入包:
2,編輯configuration,
(1)kafkawordcountproducer
選擇kafkawordcount.scala中的kafkawordcountproducer方法
vm options 設定為:-dspark.master=local
設定程式輸入引數,program arguments: localhost:9092 test 3 5
具體資訊如下
配置如下:
3,先執行kafkawordcountproducer,再執行kafkawordcount,在kafkawordcount的輸出視窗中可以看到如下兩個情況:
IDEA設定JVM執行引數
有時候我們需要在程式執行的時候對程式設定環境變數，恰巧我也遇到了這個問題，所以在此記錄一下idea是如何設定環境變數的。dproperty value 該引數通常用於設定系統級全域性變數值，如配置檔案路徑，保證該屬性在程式中任何地方都可訪問。當然，也可以通過在程式中使用system.setprope...
IDEA設定JVM執行引數
有時候我們需要在程式執行的時候對程式設定環境變數，恰巧我也遇到了這個問題，所以在此記錄一下idea是如何設定環境變數的。dproperty value 該引數通常用於設定系統級全域性變數值，如配置檔案路徑，保證該屬性在程式中任何地方都可訪問。當然，也可以通過在程式中使用system.setprope...
IDEA設定JVM執行引數
有時候我們需要在程式執行的時候對程式設定環境變數，恰巧我也遇到了這個問題，所以在此記錄一下idea是如何設定環境變數的。在程式中使用system.setproperty進行設定 dproperty value 該引數通常用於設定系統級全域性變數值，如配置檔案路徑，保證該屬性在程式中任何地方都可訪問。...