Shixiong Zhu created SPARK-26267:
------------------------------------
Summary: Kafka source may reprocess data
Key: SPARK-26267
URL: https://issues.apache.org/jira/browse/SPARK-26267
Project: Spark
Issue Type: Bug
Components: Structured Streaming
Affects Versions: 2.4.0
Reporter: Shixiong Zhu
Due to KAFKA-7703, when the Kafka source tries to get the latest offset, it may
get an earliest offset, and then it will reprocess messages that have been
processed when it gets the correct latest offset in the next batch.
This usually happens when restarting a streaming query.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
