函數(shù) def關(guān)鍵字定義函數(shù) 函數(shù)可以有默認(rèn)值弦牡,調(diào)用時不傳承則為默認(rèn)值 函數(shù)可以省略return 返回類型可以自動推導(dǎo) 如果函數(shù)體只有一行秸架,可以省...
本文的目標(biāo)在于幫助熟悉Java的同學(xué)可以快速掌握Scala的特殊語法 HelloWorld object關(guān)鍵字用于定義Scala的伴生對象惋戏,伴生...
Topic相關(guān)操作 需要注意刪除topic時要保證該topic沒有被其他消費(fèi)者消費(fèi) 按group查看延遲 結(jié)果如下: 重置group的offse...
增加插件assembly环鲤,將項目打包為zip包 在pom.xml中增加如下配置 在src/main/resources下增加如下配置 這個配置適...
安裝Hdfs 由于Flink Standalone需要依賴Hdfs温数,因此需要先安裝Hdfs古徒,這里使用hadoop 2.6.5 版本進(jìn)行安裝 下載...
背景 flink默認(rèn)會把所有日志打印到taskexecutor的日志爆雹,日志混雜在一起很難排查性穿,并且會越來越大可以通過的以下的方式分割離職并做Ro...
kafka鑒權(quán)PLAIN策略的自定義擴(kuò)展 官方文檔中PLAIN策略不推薦在線上環(huán)境使用jaas文件進(jìn)行用戶名密碼的配置勺三,但如何進(jìn)行擴(kuò)展講的不是很...
kafka配置SASL/PLAIN與權(quán)限管理調(diào)研 配置SASL鑒權(quán) 配置kafka_server_jaas.conf配置文件 修改服務(wù)端配置 修...
kafka單機(jī)安裝&配置安全證書 單機(jī)kafka安裝 下載安裝包 修改配置啟動Kafka 創(chuàng)建topic測試一下生產(chǎn)消費(fèi)數(shù)據(jù) 安全證書配置 SS...