Spring Boot优雅停机是否会停止Kafka/SQS监听器接收新消息？

1. server.shutdown=graceful对监听器的作用（Spring Boot 2.3+） #

• 先明确：HTTP请求的处理逻辑你说的没错——停止接收新请求，等正在处理的请求做完再关机。
• 针对Kafka监听器：Spring Boot 2.3+配合Spring Kafka（2.5及以上版本）的适配，开了优雅停机后，会自动做这几件事：
  • 立刻停止从Kafka拉取新消息（消费者不再发起新的poll请求）
  • 等待当前正在处理的消息消费完成，包括事务内的消息（如果开启了事务）
  • 最后提交消费偏移量，正常关闭消费者客户端
• 针对SQS监听器（比如使用Spring Cloud AWS的SQS组件）：同样，优雅停机时会先停掉轮询新消息的逻辑，等手里正在处理的消息都完成后，再关闭监听器容器。

注意：这些行为的前提是你用的starter已经支持和Spring Boot优雅停机的集成，比如Spring Kafka和Spring Cloud AWS的SQS都是在后续版本里完善了这个适配的。

2. 旧实例停机时的多实例共存问题 #

你的担心是有道理的，但实际情况分两种场景看：

• Kafka场景：Kafka的消费者组机制会自动处理实例变化。旧实例开始优雅停机时，会主动退出消费者组，Kafka集群会触发再平衡，把旧实例负责的分区分配给新启动的实例。哪怕优雅停机过程长（比如在处理大消息），短时间内新旧实例同时在组里，但旧实例已经停了拉新消息，只会处理手头剩下的任务，不会和新实例抢消息——因为再平衡的时候旧实例的分区已经被收回了。只要你的消费逻辑是幂等的，就算极端情况（再平衡前旧实例还在处理，新实例分到了同一个分区），也不会出数据重复或业务问题。
• SQS场景：SQS没有消费者组，靠的是消息可见性超时。旧实例停机时停了轮询新消息，新实例就会开始拿消息。旧实例正在处理的消息，只要在可见性超时内处理完，就会被删除；如果超时还没处理完，SQS会把消息放回队列，新实例可能会拿到这条消息。所以这里一定要确保消费逻辑是幂等的，另外可以根据业务调整可见性超时时间，减少重复消费的概率。

3. 低版本Spring Boot（<2.3）的自定义实现要点 #

如果要自己写优雅停机逻辑，核心要做到这几步：

• 监听停机信号（比如Spring的ContextClosedEvent）
• 先停掉监听器接收新消息的逻辑：
  • Kafka：调用消费者的pause()方法，或者直接关闭容器的消息轮询
  • SQS：停掉定时轮询的任务，不再发起新的receiveMessage请求
• 等所有正在处理的消息都完成（可以用计数器跟踪正在处理的任务数，等计数器归0）
• 最后关闭监听器容器和相关资源，提交Kafka的消费偏移量

实现的时候要注意：

• 处理异步任务的等待逻辑，别让主线程提前退出
• 设置合理的超时时间，不能无限等下去

内容的提问来源于stack exchange，提问作者smaxington