apache-kafka - 如何使用 Unix 时间戳通过 SimpleConsumer API 获取偏移量？

Question

我正在尝试使用SimpleConsumer 示例。

我修改代码中的偏移量：

long readOffset = getLastOffset(consumer,a_topic, a_partition, kafka.api.OffsetRequest.EarliestTime(), clientName);

当我使用kafka.api.OffsetRequest.EarliestTime()or时效果很好kafka.api.OffsetRequest.LatestTime()。但是当我将它设置为 UNIX TIMESTAMP 时，它此时不会返回消息。

例如

long readOffset = getLastOffset(consumer, a_topic, a_partition, 1439196000000L, clientName);

我将时间戳设置为 1439196000000L，即 2015/8/10 16:40:0。但是，它会在该时间前一小时左右返回一条消息。

1. 这是分配时间戳的正确方法吗？时间戳应该是 13 位，而不是 10 位，对吧？
2. 我在中国，使用北京时间。有关系吗？
3. Kafka是否有可能有任何参数来设置集群的时间？