[akka-user] Re: [Akka Streams] Sink vs Flow (or: committing offsets after writing to Kafka)

2015-10-12 Thread hbf
On Monday, 12 October 2015 10:03:06 UTC-7, Julian Howarth wrote: > > Have you looked at reactive-kafka: > https://github.com/softwaremill/reactive-kafka ? > I have looked at reactive-kaka and am following some discussions on Gitter on the subject. > We use the method documented in the

[akka-user] Re: [Akka Streams] Sink vs Flow (or: committing offsets after writing to Kafka)

2015-10-12 Thread Julian Howarth
Have you looked at reactive-kafka: https://github.com/softwaremill/reactive-kafka ? We use the method documented in the Manual Commit section of that page which works well for us. Basically, it automatically commits some configurable period of time after your processing of the message is