卡夫卡集成指南-我正在经历星火结构化数据流在这里.
在这个链接上被告知
enable.auto.commit:Kafka源不提交任何偏移量.
那么一旦我的spark应用程序成功处理了每条记录,我该如何手动提交偏移？
apache-kafka apache-spark spark-structured-streaming
apache-kafka ×1
apache-spark ×1
spark-structured-streaming ×1