I'm using Spark 2.0.2 and running a structured streaming query. When I set startingOffsets to earliest I get the following timeout errors:
java.lang.AssertionError: assertion failed: Failed to get records for spark-kafka-source-be89d84c-f6e9-4d2b-b6cd-570942dc7d5d-185814897-executor my-favorite-topic-0 1127918 after polling for 2048 I do not get these errors when I set startingOffsets to latest.
