GitHub / tresata/spark-kafka issues and pull requests
#6 - Sort partitions to comply with spark internal checks
Pull Request -
State: open - Opened by spajus almost 8 years ago
#5 - Kafka 0.10.x support
Issue -
State: open - Opened by ov7a over 8 years ago
- 1 comment
#4 - Utility method to get smallest and largest offsets for partitions
Pull Request -
State: closed - Opened by ov7a over 8 years ago
#3 - equals method overriding is missing
Issue -
State: closed - Opened by ayoub-benali about 9 years ago
- 2 comments
#2 - java.util.NoSuchElementException on Kafka message over 74 characters
Issue -
State: closed - Opened by simno almost 10 years ago
- 2 comments
#1 - Input d stream update state by key
Pull Request -
State: open - Opened by vincentye38 over 10 years ago