Are you using the new consumer API (KafkaConsumer) or the older ZookeeperConnector?
KafkaConsumer has seek() API allowing you to replay events from any point. You can also manually commit a specific offset. Gwen On Tue, Nov 24, 2015 at 2:11 PM, Jack Lund <jack.l...@braintreepayments.com> wrote: > We’re running Kafka 0.9.0, and storing our offsets in Kafka. We need a way > to reset the offsets for a consumer so that we can replay the stream. We > looked at this wiki page: > > https://cwiki.apache.org/confluence/display/KAFKA/Committing+and+fetching+consumer+offsets+in+Kafka > , > but the code doesn’t seem to be valid any more (for instance, > kafka.javaapi.ConsumerMetadataRequest and Response don’t seem to exist any > more). > > Is there any updated code snippets for fetching/committing offsets in > Kafka? > > Thanks > > -Jack Lund > Braintree Payments > >
