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.