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
