Github user jerryshao commented on the issue: https://github.com/apache/spark/pull/19274 This is because it is the only way to guarantee the ordering of data in Kafka partition mapping to Spark partition. Maybe some other users took as as an assumption to write the code. Let's see others' feedbacks. Ping @zsxwing @koeninger would you please weigh in this PR? Thanks!
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org