kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Buschman <david.busch...@timeli.io>
Subject Re: Low-level Consumer Example (Scala)
Date Wed, 06 Apr 2016 09:01:19 GMT
I use https://github.com/akka/reactive-kafka <https://github.com/akka/reactive-kafka>.
This library has just been taken over by the Akka team and will in incorporated into future
version of Akka.

It allows for at-least-once semantics as well as at-most-once semantics. 

WARNING:  The new API ( v0.11.X) is unproven, you might start with 0.10.X first, which is
the version I am using now.


David Buschman

> On Apr 5, 2016, at 1:58 PM, Afshartous, Nick <nafshartous@turbine.com> wrote:
> Hi,
> I'm looking for a complete low-level consumer example.  Ideally one in Scala that continuously
consumes from a topic and commits offsets.
> Thanks for any pointers,
> --
>     Nick

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message