dibbhatt/kafka-spark-consumer

Spark Streaming 向けの高性能な Kafka Connector。マルチトピックフェッチ、Kafka セキュリティをサポート。Zookeeper による信頼性の高いオフセット管理。データ損失なし。HDFS や WAL への依存なし。組み込みの PID レートコントローラー。メッセージハンドラーをサポート。オフセットラグチェッカー。