nequissimus / nequi-kafka 0.4.0

GitHub

Kafka (Streams) extensions/helpers

Scala versions: 2.12

nequi-kafka

Kafka (Streams) extensions/helpers

Small extensions that help with stats collection towards StatsD and DataDog

libraryDependencies += "com.nequissimus" %% "kafka-streams-statsd" % "<VERSION>"

import nequi.kafka.streams.statsd.imports._

// This will bring in extensions to KStream[K, V]