有没有可能根据接收信息的时间段来使用Kafka的信息？示例：我希望在今天的0900-1000（现在是1200）之间将所有消息接收到一个主题。如果只有一种方法可以指定开始时间，那没关系——我的消费者可以在到达结束时间后停止处理消息。我可以看到从给定偏移量请求消息、获取第一个可用偏移量和最早可用偏移量的方法，但不是给定时间之后的所有消息。
2vuwiymt1#
你可以用这个 offsetsForTimes 方法返回时间戳大于或等于给定时间戳的偏移量。有关官方文件的更多信息，请点击此处：https://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#offsetsfortimes（java.util.map）在得到偏移量之后，你可以用它来寻找并从那里开始读取。
offsetsForTimes
1条答案
按热度按时间2vuwiymt1#
你可以用这个
offsetsForTimes方法返回时间戳大于或等于给定时间戳的偏移量。有关官方文件的更多信息，请点击此处：https://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#offsetsfortimes（java.util.map）
在得到偏移量之后，你可以用它来寻找并从那里开始读取。