You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Andrew Pennebaker <an...@gmail.com> on 2016/01/26 22:10:10 UTC

facade libs for kafka?

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

Re: facade libs for kafka?

Posted by Krzysztof Ciesielski <kr...@softwaremill.pl>.

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 (andrew.pennebaker@gmail.com) 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