Hi Andrew, I’m the main maintainer of Reactive-Kafka which wraps Kafka as a sink/source of a Reactive Stream. Maybe it will suit your needs: https://github.com/softwaremill/reactive-kafka
Java API is also available. — Bests, Krzysiek SoftwareMill On 26 January 2016 at 22:10:13, Andrew Pennebaker ([email protected]) wrote: The Apache Kafka Java library requires an inordinate amount of code to send/receive messages. Has anyone thought of writing a wrapper library to make kafka easier to use? * Assume more default values * Easier access to message iterators / listening-reacting loops * Consumer thread pools * Easy topic-group offset resets, for clearing old messages before tests run -- Cheers, Andrew
