关于kafka消息订阅的问题

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

假如当前时间是 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条消息,订阅者不会收到?



发表于 1月前

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

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

      • 找不到想要的答案?

        我要提问
        相关