Re: about Exactly-once Semantics

2017-07-02 Thread Hans Jespersen
When you write the msg results to MySQL, you include the offset of the message with the results. This can be done in one atomic write transaction. Then if your application crashes, when it starts back up, it should read the offset stored with the last message results in the database, then seek()

about Exactly-once Semantics

2017-07-01 Thread fuyou
I read the great blog about kafka Exactly-once Semantics . my question is when consumer receive msg,and process the msg result save to db(eg.MySQL),how to keep Exactly-once Semantics. I think the k