Hi All, Could I request a review on this patch on Spark-Kinesis streaming. It has been sitting there for few months looking for some love. Please help.
The patch proposes resuming Kinesis data from a specified timestamp, similar to Kafka, and improves kinesis crash recovery avoiding scanning ok un-necessary data. https://github.com/apache/spark/pull/18029 Best Regards, Yash