星风的主页 - OrcHome

凸逼男勃丸回复星风在我用的springboot自带的监听注解 @KafkaListener(topics = "test") ，这种是一监听到新消息就会收到消息，还是有个默认的拉取消息间隔时间。中：

。。。因为消费者对自己拉取消息的主题分区是有监听的。。有消息过来会实时收到通知去拉取。

3年前

半兽人回复星风在我用的springboot自带的监听注解 @KafkaListener(topics = "test") ，这种是一监听到新消息就会收到消息，还是有个默认的拉取消息间隔时间。中：

结贴吧。

5年前

星风回复半兽人在我用的springboot自带的监听注解 @KafkaListener(topics = "test") ，这种是一监听到新消息就会收到消息，还是有个默认的拉取消息间隔时间。中：

醍醐灌顶啊，难怪这么高性能

5年前

半兽人回复星风在我用的springboot自带的监听注解 @KafkaListener(topics = "test") ，这种是一监听到新消息就会收到消息，还是有个默认的拉取消息间隔时间。中：

如果pull都有默认等待时间，kafka怎么能如此高性能呢？
比如，我pull一次消息，发现是空，那下次就按照“默认休眠时间”之后在去拉，如果每次消息都有，就无需等待了。

5年前

星风回复半兽人在我用的springboot自带的监听注解 @KafkaListener(topics = "test") ，这种是一监听到新消息就会收到消息，还是有个默认的拉取消息间隔时间。中：

如果集群中持续有新消息，则不会做任何等待。这句话怎么理解? 难道消费者这边不是每隔这个时间间隔才pull一次吗？是怎么做到的一有新消息就立马会消费，不会等待的？求大神指点下

5年前

5年前