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
