|
|
|
SPARK-18283
|
SPARK-15406
Add a test to make sure the default starting offset is latest
|
Tathagata Das
|
Tathagata Das
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-17837
|
SPARK-15406
Disaster recovery of offsets from WAL
|
Unassigned
|
Cody Koeninger
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
SPARK-17834
|
SPARK-15406
Fetch the earliest offsets manually in KafkaSource instead of counting on KafkaConsumer
|
Shixiong Zhu
|
Shixiong Zhu
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-17813
|
SPARK-15406
Maximum data per trigger
|
Cody Koeninger
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-17812
|
SPARK-15406
More granular control of starting offsets (assign)
|
Cody Koeninger
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-17346
|
SPARK-15406
Kafka 0.10 support in Structured Streaming
|
Shixiong Zhu
|
Frederick Reiss
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-17345
|
SPARK-15406
Prerequisites for Kafka 0.10 support in Structured Streaming
|
Unassigned
|
Frederick Reiss
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
SPARK-17343
|
SPARK-15406
Prerequisites for Kafka 0.8 support in Structured Streaming
|
Unassigned
|
Frederick Reiss
|
|
Closed |
Won't Fix
|
|
|
|
|