关于kafka消息订阅的问题

開開新新 发表于: 2021-03-12   最后更新时间: 2021-03-12 11:00:25   772 游览

假如当前时间是 2021-03-12 09:17:00

1、使用早于当前的时间
{"userid":"100278","parentid":null,"invitetype":0,"inviteurl":null,"inviteurlparam":"null","createtime":"2021-03-12 08:44:00"}

2、使用当前时间
{"userid":"100278","parentid":null,"invitetype":0,"inviteurl":null,"inviteurlparam":"null","createtime":"2021-03-12 09:16:44"}

3、使用今天下午的时间
{"userid":"100278","parentid":null,"invitetype":0,"inviteurl":null,"inviteurlparam":"null","createtime":"2021-03-12 13:17:00"}

我往topic里发送了三条消息,为什么第3条消息,订阅者不会收到?

发表于 2021-03-12
添加评论

有点抽象,需要你描述一下你的测试方式。
另外,你这个时间不是属于消息本身的吗?

開開新新 -> 半兽人 3年前

就只是普通的消息订阅案例,订阅轮询方法时按key循环的,我昨天因为遇到一个问题,正巧做了一个测试。 往一个topic里写入超过当前时间的createtime,然后消费者就不会收到这条消息。

测试的方法就是,往kafka手动插入上面的三条消息。

你的答案

查看kafka相关的其他问题或提一个您自己的问题