spark-kafka-0-8-sql icon indicating copy to clipboard operation
spark-kafka-0-8-sql copied to clipboard

Spark Structured Streaming Kafka 0.8 Source Implementation

Results 2 spark-kafka-0-8-sql issues
Sort by recently updated
recently updated
newest added

Mainly, `KafkaSourceOffset` serialization doesn't work any more, so I do it modeled after `spark-sql-kafka-010` by hand, and keep the same interface `map[TopicAndPartition, LeaderOffset]`. Some function like `parseVersion` is private under...

Dear Saisai, Thanks a lot for your contribution. I had problems at the first step when packaging it. Maven complains that it cannot find many dependencies with version number `2.1.0-SNAPSHOT`....