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

半兽人 发表于: 2018-06-20   最后更新时间: 2018-08-20  

项目说明

通过传入开始和结束时间戳,重新消费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年前   最后更新时间: 1年前   游览量:5328
上一条: kafka客户端 - java
下一条: 已经是最后了!

  • 我这钱付过了,怎么查看文章?

    老铁不太友好了,想看后面 还得收费啊

    我只消费一个topic中的数据,但Map.Entry entry : map.entrySet()各个分区的一直是null咋回事

    老铁,OffsetAndTimestamp这个类是因为我版本问题所以找不到吗

    你这会导致这个时间段之后的也被消费

    怎么看啊 手机号绑定不上 提示格式不正确