See https://cwiki.apache.org/confluence/display/KAFKA/System+Tools and check the following: GetOffsetShell (not very accurate - will set your offsets to much smaller values than you really need; we log offsets frequently in application logs and get it from there) ImportZkOffsets
Kind regards, Michał Michalski, [email protected] On 18 February 2015 at 16:16, Surendranauth Hiraman <[email protected]> wrote: > We are using the High Level Consumer API to interact with Kafka. > > However, on restart in the case of failures, we want to be able to manually > reset offsets in certain situations. > > What is the recommended way to do this? > > Should we use the Simple Consumer API just for this restart case? > > Ideally, it would be great to use the same approach in 0.8.1 and in 0.8.2. > > > > SUREN HIRAMAN, VP TECHNOLOGY > Velos > Accelerating Machine Learning > > 54 West 40th Street, 3RD FLOOR > NEW YORK, NY 10018 > T: @suren_h > E: suren.hiraman@v <[email protected]>elos.io > W: www.velos.io >
