Kangaroo projects with KafkaInputformat - Mapreduce.

Hi Team, Does any one use Kangaroo Project which uses SimpleConsumer of Kafka API, that provides support to integrate with MapReduce Jobs. Facing one issue related to getting an offsets for specific consumer. Also after Re launching, the committed offsets for a consumer is to be read, and start f

Simple consumer offset help.

Hello All, I am new to Kafka, and confused in knowing things realated to offsets value that we set over partitions in specific topic using SimpleConsumer class. Would be great if anyone can tell me with example how to set an offset for specific partions , for reading from beginig or from last offs