mutatis

License	Apache-2.0
GroupId	default
ArtifactId	mutatis_2.11
Last Version	0.2.40
Release Date	Dec 15, 2017
Type	jar
Description	mutatis mutatis
Project Organization	default
Source Code Management	https://github.com/verizon/mutatis

Download mutatis_2.11

Filename	Size
mutatis_2.11-0.2.40.pom
mutatis_2.11-0.2.40.jar	55 KB
mutatis_2.11-0.2.40-sources.jar	5 KB
mutatis_2.11-0.2.40-javadoc.jar	351 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/default/mutatis_2.11/ -->
<dependency>
    <groupId>default</groupId>
    <artifactId>mutatis_2.11</artifactId>
    <version>0.2.40</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/default/mutatis_2.11/
implementation 'default:mutatis_2.11:0.2.40'

Gradle Kotlin

// https://jarcasting.com/artifacts/default/mutatis_2.11/
implementation ("default:mutatis_2.11:0.2.40")

Apache Buildr

'default:mutatis_2.11:jar:0.2.40'

Apache Ivy

<dependency org="default" name="mutatis_2.11" rev="0.2.40">
  <artifact name="mutatis_2.11" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='default', module='mutatis_2.11', version='0.2.40')
)

Scala SBT

libraryDependencies += "default" % "mutatis_2.11" % "0.2.40"

Leiningen

[default/mutatis_2.11 "0.2.40"]

Dependencies

compile (6)

Group / Artifact	Type	Version
org.scala-lang : scala-library	jar	2.11.8
org.apache.kafka : kafka_2.11	jar	0.8.2.2
org.apache.kafka : kafka_2.11	jar	0.8.2.2
com.verizon.journal : core_2.11	jar	2.2.0
org.scalaz : scalaz-core_2.11	jar	7.1.7
org.scalaz.stream : scalaz-stream_2.11	jar	0.7.3a

test (1)

Group / Artifact	Type	Version
org.scalatest : scalatest_2.11	jar	2.2.6

Project Modules

There are no modules declared in this project.

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

Verizon

Versions

Version
0.2.40 Dec 15, 2017