dibbhatt/kafka-spark-consumer

適用於 Spark Streaming 的高效能 Kafka Connector。支援多 Topic 擷取、Kafka 安全性。在 Zookeeper 中進行可靠的 offset 管理。無資料遺失。不依賴 HDFS 與 WAL。內建 PID 速率控制器。支援訊息處理常式。Offset 延遲檢查器。