spring-boot - 使用 Spring Cloud Stream Kafka 3.0.3.RELEASE 时是否可以应用正常关闭？

Question

我基于Spring Cloud Stream 3.0.3.RELEASE开发了kafka消费者应用。(SpringBoot 2.3.4.RELEASE)

当我停止这个应用程序时，我希望消费者优雅地关闭。 Similar Questions

1. 停止轮询新消息
2. 完成他们的工作并将偏移量提交给 Kafka
3. 优雅地关闭应用程序

spring cloud stream默认这个工作吗？那有相关的文档吗？

---

供您引用，我正在使用 spring cloud stream kafka，如下所示。

#Message handler
@Component
public class MessageHandler {

    @Bean
    public Consumer<MyEvent> handleMessage() {
        return message -> {...}
    }
...
}


#application.yml
spring:
  cloud:
    stream:
      bindings:
        handleMessage-in-0:
          destination: myevent
          group: test-group
          consumer:
            maxAttempts: 2
            concurrency: 10
      function:
        definition: handleMessage
...

Answer 1

如您引用的答案中所述，您可以使用 ListenerContainerCustomizer bean 增加 shutdownTimeout 容器属性(默认为 10 秒)。

@Bean
public ListenerContainerCustomizer<AbstractMessageListenerContainer<?, ?>> customizer() {
    return (container, dest, group) -> container.getContainerProperties()
            .setShutdownTimeout(30_000L);
}