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
