In
http://apache.osuosl.org/kafka/0.8.2-beta/scala-doc/index.html#kafka.consumer.SimpleConsumer class SimpleConsumer: def earliestOrLatestOffset(topicAndPartition: TopicAndPartition, earliestOrLatest: Long, consumerId:Int): Long 1) What's the consumerId? It doesn't seem to matter what value I put here, nor do I understand why its needed (since the isn't the query used to lookup the head and tail offsets -- aren't these properties consumer-independent?) Also 2) What's the difference between: class SimpleConsumer: def earliestOrLatestOffset(topicAndPartition: TopicAndPartition, earliestOrLatest: Long, consumerId:Int): Long def getOffsetsBefore(request: OffsetRequest): OffsetResponse both of these method seem to return the head or tail offsets. Thanks - Stu
