You need to commit messages either manually or enable auto commit via "auto.commit.enable = true".
-Matthias On 08/10/2016 07:34 PM, Auduru Suresh wrote: > Hi , > > We've wrote kafka consumer and for each restart it is reading messages from > starting of partition . Please help me how we can make it read from last > offset. > Also, please subscribe me to the forum. > > Thanks, Suresh >
signature.asc
Description: OpenPGP digital signature
