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.
Thanks,
DaVe.
David Buschman
d...@timeli.io
> On Apr 5, 2016, at 1:58 PM, Afshartous, Nick <nafshart...@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
