I'm using Spark 2.0.2 and running a structured streaming query. When I
to earliest I get the following timeout errors:
java.lang.AssertionError: assertion failed: Failed to get records for
my-favorite-topic-0 1127918 after polling for 2048
I do not get these errors when I set startingOffsets to latest.