小编iti*_*pa1的帖子

我需要消耗特定的偏移量到特定的结束偏移量！！consumer.seek() 从特定偏移量读取数据，但我需要将数据从偏移量检索到 tooffset ！！任何帮助将不胜感激，提前致谢。

    ConsumerRecords<String, String> records = consumer.poll(100);
    if(flag) {
        consumer.seek(new TopicPartition("topic-1", 0), 90);
        flag = false;
    }

当我尝试运行它时，我尝试根据时间戳获取 Kafka 主题的偏移量，它抛出空指针错误，

Map<TopicPartition, Long> timestampsToSearch = new HashMap<>();
              for (TopicPartition partition : partitions) {
                timestampsToSearch.put(partition,  startTimestamp);
              }
Map<TopicPartition, OffsetAndTimestamp> outOffsets = consumer.offsetsForTimes(timestampsToSearch);
              for (TopicPartition partition : partitions) {
                Long seekOffset = outOffsets.get(partition).offset();
consumer.seek(partition, seekOffset);

任何帮助将不胜感激。