verizon / mutatis   0.2.42

Apache License 2.0 GitHub

Kafka consumer & producer for scalaz-stream

Scala versions: 2.11


Build Status Maven Central

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.


Set up kafka server. To do this, download and start Zookeeper and Kafka, as per


  • create a topic called "test8" with 8 partitions:
   ./bin/ --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.


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