Hudi 数据湖的插入,更新,查询,分析操作示例( 三 )

其中
properties.setProperty("bootstrap.servers", "192.168.100.130:9092");根据自己的配置调整,然后通过 kakfa 的生产者客户端输入一些数据,这边可以收到这个数据,验证完毕 。
完整代码见
data-lake

推荐阅读