-
Kafka Binary files : http://kafka.apache.org/downloads.html
-
Atleast 2 AWS machines : AWS EMR or EC2 will be preferable
-
A Kafka Manager Utility to watch up the Cluster : https://cwiki.apache.org/confluence/display/KAFKA/Ecosystem
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| /** | |
| * D Holbrook | |
| * | |
| * Code Club: PO1 | |
| * | |
| * (*) Define a binary tree data structure and related fundamental operations. | |
| * | |
| * Use whichever language features are the best fit (this will depend on the language you have selected). The following operations should be supported: | |
| * | |
| * Constructors |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package pc | |
| import akka.actor.Actor | |
| import akka.actor.Props | |
| import akka.actor.ActorRef | |
| import akka.actor.ActorRefFactory | |
| class Parent extends Actor { | |
| val child = context.actorOf(Props[Child], "child") | |
| var ponged = false |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.util.zip.ZipFile | |
| import java.io.FileInputStream | |
| import java.io.FileOutputStream | |
| import scala.collection.JavaConversions._ | |
| import java.util.zip.ZipEntry | |
| import java.io.InputStream | |
| import java.io.OutputStream | |
| import java.io.File | |
| class ZipArchive { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.specs2._ | |
| import execute._ | |
| import specification._ | |
| import core._ | |
| class TestSuite(tests: Fragment*) extends Specification { | |
| def is = br ^ Fragments.foreach(tests)(f => Fragments(f, br)) | |
| } | |
| object TestSuite { |