在spark文档中提到，foreachbatch不支持完全一次交付语义，只能支持至少一次语义。与Kafka相比，我们怎样才能实现它？我们可以使用批标识和重复数据消除作为提示。
在这里，我阅读了kafka的文章，并用foreachbatch的结构化流式api给kafka写信。