kafka通过开始和结束时间,重新消费消息 - java

项目说明

通过传入开始和结束时间戳,重新消费kafka历史消息。

public static void main(String[] args) {

    String startTime = "2018-08-14 21:19:09";       // 开始时间
    String endTime = "2018-08-14 21:20:59";         // 结束时间
    //        endTime = "";         // 不设置结束时间
    new ReConsumerByTime().start(startTime, endTime);
}


您需要解锁本帖隐藏内容请: 点击这里





发表于: 1年前   最后更新时间: 9月前   游览量:4393
上一条: 手把手教你写Kafka Streams程序
下一条: test

  • 我只消费一个topic中的数据,但Map.Entry entry : map.entrySet()各个分区的一直是null咋回事
    老铁,OffsetAndTimestamp这个类是因为我版本问题所以找不到吗
    你这会导致这个时间段之后的也被消费
    怎么看啊 手机号绑定不上 提示格式不正确