scala 自己实现Deltastreamer(使用spark struct streaming),实现多topic的kafka数据写入到Hudi ㅤ 发表于2024-06-26 浏览5199 评论0 1 提交scala程序到Spark 1.1 使用shell spark-shell --packages org.apache.hudi:hudi-spark-bundle_2.11:0.8.0,org.apache.spark:spark-avro_2.11:2.4.4,org.apache.spark:spark-sql-kafka-0-10_2.11:2.4.8,com.googlecode.json-simple:json-simple:1.1,com.alibaba:f