You can do this using the SimpleConsumer. See https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example for details with some code.
When the new consumer is released in 0.8.3, this will get a *lot* simpler. -Ewen On Fri, Aug 7, 2015 at 9:26 AM, Padgett, Ben <bpadg...@illumina.com> wrote: > Does anyone have an example of how to get a single record from a > topic+partition given a specific offset? > > I am interested in this for some retry logic for failed messages. > > Thanks! > > -- Thanks, Ewen
