spark-kafka-0-8-sql
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`....