Hudi 數據湖的插入,更新,查詢,分析操作示例( 三 )

其中
properties.setProperty("bootstrap.servers", "192.168.100.130:9092");根據自己的配置調整,然后通過 kakfa 的生產者客戶端輸入一些數據,這邊可以收到這個數據,驗證完畢 。
完整代碼見
data-lake

推薦閱讀