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);
}


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





发表于: 5月前   最后更新时间: 3月前   游览量:2179
上一条: 手把手教你写Kafka Streams程序
下一条:

评论…


  • 你这会导致这个时间段之后的也被消费
    怎么看啊 手机号绑定不上 提示格式不正确
  • 评论…
    • in this conversation