状态清理
默认情况下,绑定停止时不会清理本地状态。这与 Spring Kafka 2.7 版本以来的行为一致。更多详细信息请参阅 Spring Kafka documentation。要修改此行为,只需向应用上下文添加一个单独的 CleanupConfig
@Bean
(配置为在启动时、停止时或都不清理);该 Bean 将被检测到并注入到工厂 Bean 中。
默认情况下,绑定停止时不会清理本地状态。这与 Spring Kafka 2.7 版本以来的行为一致。更多详细信息请参阅 Spring Kafka documentation。要修改此行为,只需向应用上下文添加一个单独的 CleanupConfig
@Bean
(配置为在启动时、停止时或都不清理);该 Bean 将被检测到并注入到工厂 Bean 中。