回答情况：
提问时间：
问题标签：
我使用spark-structured-streaming作为消费者从kafka获取数据，按照指南参考https://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html我知道spark-structured-streaming使用检查点进行恢复，但由于一些数据已经写为拼图，我不确定偏移量是否被标记为提交。
浏览 20修改于2019-05-27得票数 0
所以现在使用Spark-structured-streaming，我很惊讶检查点只有HDFS。用Kafka来勾点会更快更可靠。
浏览 39提问于2021-05-07得票数 2
我可以在我的Spark-Structured-Streaming中使用Bahir的替代方案来连接到ActiveMQ主题吗？
浏览 24修改于2020-12-10得票数 1
回答已采纳
2回答
val spark = SparkSession .appName("Spark-Structured-Streaming")def main(args: Array[String]): Unit = {
val spark = SparkSession.builder.appName("Spark-Structured-Streamingusing builtin-java classes whe
浏览 3修改于2020-05-30得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号