Re: Low-level Consumer Example (Scala)

ssing .to(consumerWithOffsetSink.offsetCommitSink) // stream back for commit .run() From: David Buschman Sent: Wednesday, April 6, 2016 5:01 AM To: users@kafka.apache.org Subject: Re: Low-level Consumer Example (Scala) I use https://github.com/akka/react

Re: Low-level Consumer Example (Scala)

I use 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 ( v

Low-level Consumer Example (Scala)

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