dibbhatt/kafka-spark-consumer

适用于 Spark Streaming 的高性能 Kafka Connector。支持多 Topic 获取、Kafka 安全性。在 Zookeeper 中进行可靠的 offset 管理。无数据丢失。不依赖 HDFS 与 WAL。内置 PID 速率控制器。支持消息处理器。Offset 延迟检查器。