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