Re: Kafka and Rx

2014-06-16 Thread Neha Narkhede
For that reasons I am now attempting to use your new, not released yet, 0.9 consumer API - I have an impression that it is more or less stable at the moment, am I right? Can you estimate when will you finish and release version 0.9? The API is checked into trunk and I would not rule out minor chan

Kafka and Rx

2014-06-15 Thread Marta Kacperek
Dear Kafka developers and users, I am currently working on creating a small library that would enable using Reactive Extensions (Rx) with Kafka as data source. I started with what seemed most reasonable for me: using Kafka's Java API and wrapping Kafka producers and consumers with RxJava interf