Tao, You can use manual offset commit in the high level consumer. Basically, call offset commit only after the data has been successfully processed.
Thanks, Jun On Mon, Jun 18, 2012 at 10:41 PM, tao li <tust.05102...@gmail.com> wrote: > hi, all > > In my project, we want to consume the msg in kafka in the transaction, so, > when the transaction rollback, we need the kafka offset back to the > point transaction begin, I use the consumer Low-level API make it, it's too > complex, how to make Transaction get with the consumer High-level API if > is possible. > > Best regards, > > litao >
