dibbhatt/kafka-spark-consumer

Spark Streaming के लिए उच्च प्रदर्शन वाला Kafka कनेक्टर। मल्टी-टॉपिक फेच और Kafka सुरक्षा का समर्थन करता है। Zookeeper में विश्वसनीय ऑफसेट प्रबंधन। कोई डेटा हानि नहीं। HDFS और WAL पर कोई निर्भरता नहीं। इन-बिल्ट PID रेट कंट्रोलर। मैसेज हैंडलर और ऑफसेट लैग चेकर का समर्थन।