如何在Spark 3.0中使用kafka.group.id避免始终启动最新位置的偏移量?
Based on the introduction in Spark 3.0, https://spark.apache.org/docs/latest/structured-streaming-kafka-integration.html. It should be possible to set "kafka.group.id" to track the offset. For our use case, I want to avoid the potential data loss if the st...