From b7ebc185e7e5ee81801dc8e34b076f5eb3a85822 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Mon, 13 Sep 2021 15:32:07 -0400 Subject: [PATCH] GH-1141: Streams cleanup docs Clarify streams cleanup default in the docs. Effective from Spring Kafka 2.7, no cleanup will be performed on shutdown. Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1141 --- docs/src/main/asciidoc/kafka-streams.adoc | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/docs/src/main/asciidoc/kafka-streams.adoc b/docs/src/main/asciidoc/kafka-streams.adoc index 5fc0bc419..fb24721e8 100644 --- a/docs/src/main/asciidoc/kafka-streams.adoc +++ b/docs/src/main/asciidoc/kafka-streams.adoc @@ -1718,8 +1718,9 @@ spring.cloud.stream.bindings.enrichOrder-out-0.binder=kafka1 #kstream === State Cleanup -By default, the `Kafkastreams.cleanup()` method is called when the binding is stopped. -See https://docs.spring.io/spring-kafka/reference/html/_reference.html#_configuration[the Spring Kafka documentation]. +By default, no local state is cleaned up when the binding is stopped. +This is the same behavior effective from Spring Kafka version 2.7. +See https://docs.spring.io/spring-kafka/reference/html/#streams-config[Spring Kafka documentation] for more details. To modify this behavior simply add a single `CleanupConfig` `@Bean` (configured to clean up on start, stop, or neither) to the application context; the bean will be detected and wired into the factory bean. === Kafka Streams topology visualization