是否可以根据消息被摄取的时间段来消费来自Kafka的消息？
示例:我希望今天0900-1000之间的所有消息都被提取到主题(现在是1200).
如果只有一种方法来指定开始时间,那很好 - 我的消费者可以在消息到达结束时间时停止处理消息.
我可以看到从给定偏移量请求消息,获取第一个可用偏移量以及最早可用偏移量的方法,但不能查看给定时间后的所有消息.
apache-kafka kafka-consumer-api
apache-kafka ×1
kafka-consumer-api ×1