mutatis

Scalaz Streams wrapper for Kafka Producer and Consumer

Getting Started

These instructions will get a copy of the project up and running on your local machine for development and testing purposes.

Prerequisites

Set up kafka server. To do this, download and start Zookeeper and Kafka, as per https://kafka.apache.org/082/documentation.html#quickstart

Installing

• create a topic called "test8" with 8 partitions:

   ./bin/kafka-topics.sh --create \
   --zookeeper localhost:2181 \
   --replication-factor 1 \
   --partitions 8 \
   --topic test8

• Start producer - notice one message is produced every 100 milliseconds:

   sbt "test:run-main mutatis.ExampleProducer"

• Start consumer - notice one message takes 250 milliseconds to process, one consumer is not enough:

   sbt "test:run-main mutatis.ExampleConsumer"

See src/test/scala/mutatis/example.scala for a complete example

Running the tests

sbt test

Built With

• Kafka - A distributed streaming platform
• Scalaz - An extension to the core Scala library for functional programming.

Versioning

We use SemVer for versioning. For the versions available, see the tags on this repository.

Authors

• https://github.com/dougkang
• https://github.com/haripriyamurthy
• https://github.com/rolandomanrique
• https://github.com/kothari-pk