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

半兽人 发表于: 2018-06-20   最后更新时间: 2021-09-05 09:46:42  
{{totalSubscript}} 订阅, 10,278 游览

项目说明

通过传入开始和结束时间戳,重新消费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);
}


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


上一条: kafka客户端 - java
下一条: 已经是最后了!

这个kafka是多少版本的,我找不到OffsetAndTimestamp这个方法和consumer.offsetsForTimes这个方法,我的是0.10的

Kafka 0.11.0以上都可以。

把我殺掉- 1年前

好兄弟 我报错了 Failed to get offsets by times in 60000ms

这个是网络不通,你要检查下执行环境和kafka集群之间的网络。

问题是TopicPartiton有值 但是OffsetAndTimestamp没有值 然后就一直导致获取不到 报哪个超时异常

knightchong 1年前

哎 写的都不对 无语

半兽人 -> knightchong 1年前

?哪里不对

半兽人 -> knightchong 1年前

你连看都没看 就说不对?

代码没问题,可以正常使用,不要散播谣言。

红豆生南国 2年前

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

直接购买即可

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

兄弟,只收1块钱,而且就1、2篇文章才收费....

MIAO 丶 2年前

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

半兽人 -> MIAO 丶 2年前

到问题专区里 详细描述一下吧。

Paddy 2年前

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

半兽人 -> Paddy 2年前

看来你的版本很陈旧,我记得是1.10以后才有这个的。

heartOfgod 3年前

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

半兽人 -> heartOfgod 3年前

有过滤呀

磊丶 3年前

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

半兽人 -> 磊丶 3年前

你邮箱留的QQ号不对吧。我加你了

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章
找不到想要的答案?

我要提问
提问