A Simple App that instantiates a file data transfer between a local producer and a local consumer
Install dependencies:
$ pip install -r requirements.txt
https://kafka.apache.org/quickstart
Change server.properties to localhost advertised listener
$ JMX_PORT=8004 bin/kafka-server-start.sh config/server.properties
$ bin/zookeeper-server-start.sh config/zookeeper.properties
$ bin/kafka-console-consumer.sh --topic quickstart-events --bootstrap-server localhost:9092
$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
git clone [email protected]:yahoo/CMAK.git
cd CMAK/target/universal/cmak-3.0.0.5
$ bin/cmak -Dconfig.file=conf/application.conf -Dhttp.port=8080