michal-harish/graphstream
Example application of the Recursive Stream Processor
A simple web application scans zookeeper for topics and which consumer groups consum them and tries to detect also whether they are "active" by looking how far behind the latest offsets of the respective kafka partitions they are. It could also be an interface to create and delete topics.
Public repository record indexed from GitHub. Explore verified star velocity metrics, source code repositories, and curated developer tool directories across the GitHubRepo ecosystem.
Example application of the Recursive Stream Processor
Scalable complex event processor built around kafka - it uses kafka consumers as a source of primary events as well as for producting intermediate and higher-order events
Generic spark module for scanning, joining and mutating HBase tables to and from RDDs.
Simple Yarn Executor