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


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






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

评论…


  • 评论…
    • in this conversation