Scalaz Streams wrapper for Kafka Producer and Consumer
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 https://kafka.apache.org/082/documentation.html#quickstart
- 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
sbt test
- 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.
