High throughput asynchronous task processing on Apache Kafka

Decaton Decaton is a streaming task processing framework built on top of Apache Kafka. It is designed to enable "concurrent processing of records consumed from one partition" which isn't possible in many Kafka consumer framewor

Related Repos



takipi About An open source project by OverOps. Visit the site to download a sample result or read more on the blog Requirements Groovy installed Gradle installed Java installed Installation Downlo
 

mogenslund Salza λiquid text editor Fluidable - Embed your code into λiquid or λiquid into your code Dependency free - Everything is pure Clojure Translatable - Tiny core, simple model, no tricks Comfortable keybindings - Mos
 

nanosai ModRun - Modularity for Java Without Jigsaw ModRun can load and run classes directly from Maven repositories and resolve dependencies at runtime. For a more complete tutorial, read this: ModRun Tutorialhttp://tutorials.jenkov.co
 
Popular
4.6k

apache Apache Beam (incubating) Apache Beam is a unified model for defining both batch and streaming data-parallel processing pipelines, as well as a set of language-specific SDKs for constructing pipelines and Runners for executing the
 

apache Myriad Myriad is a Mesos framework designed for scaling a YARN cluster on Mesos. Myriad can expand or shrink the resources managed by a YARN cluster in response to events as per configured rules and policies. The name Myriad m
 

kira8565 Introduction Elastic-Grok-Script-Plugin is a provider of Grok ElasticSearch plug-in Install fork this project and change the elasticsearch in maven ,default is 2.3.3 run mvn assembly:assembly ,you can find the re
 

apache Apache Tamaya (incubating) Tamaya is a very powerful yet flexible configuration solution. It's core is built based on a few simple concepts. There are at least two main usage scenarios for Tamaya, which are synergetic: In an
 

HCADatalab powderkeg Live-coding the cluster! Usage First, add Powderkeg and Spark (1.5 to 2.1 are supported, any scala version) to your dependencies: E.g. :dependencies [[hcadatalab/powderkeg "0.5.1"] [com.