我可以在使用Spring Cloud Stream Kafka 3.0.3时应用优雅关机吗。释放？

Question

我开发了基于Spring Cloud Stream 3.0.3的kafka消费者应用程序。发布。（SpringBoot 2.3.4。发布）

当我停止此应用程序时，我希望消费者优雅地关闭。类似的问题

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

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增加容器属性（默认10秒）。

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