kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rafeeq s <rafeeq.ec...@gmail.com>
Subject SimpleConsumer kafka.api.OffsetRequest.LatestTime() not working ?
Date Wed, 18 Jun 2014 13:19:34 GMT
Simple Consumer is *not processing* messages when it's offset in
kafka.api.OffsetRequest.*LatestTime()* .

If i use *EarlierTime()  *offset method it is processing from start, which
is as expected.

But when I try for *LatestTime()* offset, no reaction from simple consumer
and I am referring below simpleconsumer example:

https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example


Regards,
Rafeeq S
*(“What you do is what matters, not what you think or say or plan.” )*

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message