problem about the offset

[jinhong lu]

Hi, all

    I try to use SimpleConsumer follow the example at 
https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example 
<https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example>.

   I modify the offset in the code:
        long readOffset = getLastOffset(consumer,a_topic, a_partition, 
kafka.api.OffsetRequest.EarliestTime(), clientName);

  It works well when I use kafka.api.OffsetRequest.EarliestTime() or 
kafka.api.OffsetRequest.LatestTime(). But when I set it to a UNIX TIMESTAMP, it 
return not the message at that moment.

   For example, 
        long readOffset = getLastOffset(consumer,a_topic, a_partition, 
1439196000000L, clientName);
 
  I set the timestamp to  1439196000000L, it means 2015/8/10 16:40:0. But it 
return the message about one hour before that time.

(1)Is it the right way to assign the time stamp? the time stamp should be 
13bit, not 10bit, right?
(2)I am in china, using Beijing time, is it has an effect?
(3) Or any possbile that kafka has any parameter to set the time of the cluster?

thanks a lot.


BR//lujinhong