Kafka4m

Kafka4m (kafka for monix) is a bit like the fs2kafka or zio-kafka, but a bit more opinionated, in that it also brings in a typesafe configuration and application setup.

It’s purpose was to be able to use the rich set of streaming features provided by monix while still having access to the data structures provided by the kafka consumer api.

You can use thinks like ‘kafka4m.loadBalance’ to execute tasks in parallel while ensuring only the offset for the most-recent successful task is committed.

Check out the latest scaladocs here