Hi, I using Akka streams to read (= consume) messages from a Kafka tropic, transform them, and write them to another Kafka topic. I am looking for a way to commit the consumer offset of a message after it was written.
Example: if I've read message *m*, I'd like to first process it and write it out to the destination topic. Only then do I want to tell Kafka "ok, I've read *m; *if i crash and restart, position me after *m*, please!" Here are a few ways to realize this: - Make the writer a Sink and give it knowledge about the consumer so it can commit the latter's offset after writing. Not nice: the sink shouldn't have to know about a consumer. - Make the writer a Flow that as a side effect writes to Kafka. Then connect this flow to a CommitSink that commits the offsets. That doesn't sound nice either, as conceptually, both are sinks. Any suggestions how to do this in The Akka Streams Way®? Thanks, K -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
