项目描述 ：
用于Spark Streaming的高性能Kafka消费者。兼容所有Spark和Kafka版本，包括最新的Spark 2.3.x和Kafka 2.0.0。现在支持Kafka Security，Kafka Headers。 Zookeeper中的偏移管理。可靠无数据丢失保证。不依赖于HDFS和WAL。内置PID速率控制器。支持消息拦截器。偏移滞后检查器。

高级语言： Java

项目主页：

项目地址: git://github.com/dibbhatt/kafka-spark-consumer.git

创建时间： 2014-08-02T11:16:45Z
项目社区：https://github.com/dibbhatt/kafka-spark-consumer
开源协议：Apache License 2.0
下载