凸逼男勃丸
0
声望
这家伙太懒,什么都没留下
个人动态
半兽人
贬了 在
我用的springboot自带的监听注解 @KafkaListener(topics = "test") ,这种是一监听到新消息就会收到消息,还是有个默认的拉取消息间隔时间。
的评论!
。。。因为消费者对自己拉取消息的主题分区是有监听的。。有消息过来会实时收到通知去拉取。
3年前
半兽人
回复
凸逼男勃丸
在
我用的springboot自带的监听注解 @KafkaListener(topics = "test") ,这种是一监听到新消息就会收到消息,还是有个默认的拉取消息间隔时间。
中 :
不是的,kafka故意设计成主动拉取消息。
消费者是主动拉取消息的
3年前
凸逼男勃丸
回复
星风
在
我用的springboot自带的监听注解 @KafkaListener(topics = "test") ,这种是一监听到新消息就会收到消息,还是有个默认的拉取消息间隔时间。
中 :
。。。因为消费者对自己拉取消息的主题分区是有监听的。。有消息过来会实时收到通知去拉取。
3年前
登录
账户
密码
取消
登录
目前只支持QQ方式登录。
其他登录方式: