1) ConsumerId is for tracking which client makes the request. It's mostly
for debugging right now.
2) The latter is more general. You can ask for an offset before an
arbitrary timestamp.
Thanks,
Jun
On Sun, Feb 22, 2015 at 6:35 PM, Stuart Reynolds s...@stureynolds.com
wrote:
In
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
