我有一个3节点Kafka集群设置。我用暴风来读Kafka的留言。我的系统中的每个主题都有7个分区。
现在我面临一个奇怪的问题。直到三天前，一切正常。但是，现在看来我的storm拓扑无法从2个分区读取具体的数据-#1和#4。
我试图深入研究这个问题，发现在我的kafka日志中，对于这两个分区，都缺少一个偏移量，即在5964511之后，下一个偏移量是5964513，而不是5964512。
由于缺少偏移量，简单使用者无法进行下一个偏移量。我是做错了什么还是一个已知的错误？
这种行为的原因可能是什么？
我使用以下代码读取有效偏移量的窗口：

public static long getLastOffset(SimpleConsumer consumer, String topic, int partition,
                                 long whichTime, String clientName) {
    TopicAndPartition topicAndPartition = new TopicAndPartition(topic, partition);
    Map<TopicAndPartition, PartitionOffsetRequestInfo> requestInfoMap = new HashMap<TopicAndPartition, PartitionOffsetRequestInfo>();
    requestInfoMap.put(topicAndPartition, new PartitionOffsetRequestInfo(kafka.api.OffsetRequest.LatestTime(), 100));
    OffsetRequest request = new OffsetRequest( requestInfoMap, kafka.api.OffsetRequest.CurrentVersion() , clientName);
    OffsetResponse response = consumer.getOffsetsBefore(request);
    long[] validOffsets = response.offsets(topic, partition);
    for (long validOffset : validOffsets) {
        System.out.println(validOffset + " : ");
    }
    long largestOffset = validOffsets[0];
    long smallestOffset = validOffsets[validOffsets.length - 1];
    System.out.println(smallestOffset + " : " + largestOffset );
    return largestOffset;
}

这将提供以下输出：

4529948 : 6000878

所以，我提供的偏移量在偏移量范围内。