假如当前时间是 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条消息，订阅者不会收到？
有点抽象，需要你描述一下你的测试方式。
另外，你这个时间不是属于消息本身的吗？
就只是普通的消息订阅案例，订阅轮询方法时按key循环的，我昨天因为遇到一个问题，正巧做了一个测试。 往一个topic里写入超过当前时间的createtime，然后消费者就不会收到这条消息。
测试的方法就是，往kafka手动插入上面的三条消息。
你的答案