kafka指定消费1分钟前的数据

要消费指定时间之前的数据，你可以使用 Kafka 的 Consumer API 中的 `seek()` 方法。以下是一个示例代码：

long timestampToSearch = System.currentTimeMillis() - 60000; // 1分钟前的时间戳
consumer.subscribe(Collections.singletonList("your_topic_name"));
consumer.poll(Duration.ZERO); // 需要先调用一次 poll() 方法，才能获取 partition
for (TopicPartition partition : consumer.assignment()) {
    consumer.seek(partition, timestampToSearch);
}
while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    // 处理记录
}

首先，我们使用 `subscribe()` 方法订阅了一个或多个主题。然后，我们调用 `poll()` 方法获取当前可消费的记录。由于我们只是想获取 partition，因此我们使用了 `Duration.ZERO` 作为超时时间。接下来，我们循环遍历每个 partition，并使用 `seek()` 方法将偏移量设置为指定时间戳之前的最近记录的偏移量。最后，我们开始消费记录并处理它们。