Pinned

1. kafka-storm-starter Public

   Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

   Scala 724 334

2. ksql-udf-examples Public

   Example implementations of KSQL UDFs and UDAFs. They are a good starting point to write your own.

   Java 6

3. wirbelsturm Public

   Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.

   Shell 333 72

4. akka-mock-scheduler Public

   A mock Akka scheduler to simplify testing scheduler-dependent code

   Scala 86 8

5. avro-hadoop-starter Public

   Example MapReduce jobs in Java, Hive, Pig, and Hadoop Streaming that work on Avro data.

   Java 112 85

6. replephant Public

   A Clojure library to interactively analyze Hadoop cluster usage via REPL

   Clojure 35 4