如何为foreachBatch的batchId设置起点?

然后在通过检查点从故障中恢复:我认为这完全涵盖了您的用例.I think that covers your use case exactly.这需要在流查询的checkpointLocation选项中使用具有预期批次ID的预填充目录.That'd require to use a pre-populated directory with the expected batch ID in the checkpointLocation option of a streaming query.您可以轻松地自己创建必要的文件，然后让恢复的流查询从目录开始.You could simply create the necessary files yourself and let resumed streaming queries start from the directory.(我以前从未尝试过，但看起来可行).(I've never tried it out myself before, but looks doable). 这篇关于如何为foreachBatch的batchId设置起点?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！