经过时间戳查询指定分区的offsets

*** 使用的方法(offsetsForTimes()):html Properties props = new Properties(); KafkaConsumer<String,String> consumer = new KafkaConsumer<>(props); java.util.Map<TopicPartition,OffsetAndTimestamp> partitionTim
相关文章
相关标签/搜索