状态清理
默认情况下,停止绑定时不会清理本地状态。从 Spring Kafka 2.7 版本开始,此行为保持一致。有关更多详细信息,请参阅Spring Kafka 文档。要修改此行为,只需将单个CleanupConfig
@Bean
(配置为在启动、停止或两者都不清理)添加到应用程序上下文;该 Bean 将被检测到并连接到工厂 Bean。
默认情况下,停止绑定时不会清理本地状态。从 Spring Kafka 2.7 版本开始,此行为保持一致。有关更多详细信息,请参阅Spring Kafka 文档。要修改此行为,只需将单个CleanupConfig
@Bean
(配置为在启动、停止或两者都不清理)添加到应用程序上下文;该 Bean 将被检测到并连接到工厂 Bean。