Spring/spring-kafka
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Configurable KafkaStreams cleanup execution

Browse Source 
542 few minor fixes

Docs, Javadocs
This commit is contained in:
pszymczyk
2018-01-25 22:20:50 +01:00
committed by Gary Russell
parent 2526509e86
commit 63b2bcb018
4 changed files with 192 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/reference/asciidoc/streams.adoc
View File

@@ -119,6 +119,9 @@ Only you need is to declare `StreamsConfig` bean with the `defaultKafkaStreamsCo
A `StreamsBuilder` bean with the `defaultKafkaStreamsBuilder` name will be declare in the application context automatically.
Any additional `StreamsBuilderFactoryBean` beans can be declared and used as well.
By default, when the factory bean is stopped, the `KafkaStreams.cleanUp()` method is called.
Starting with _version 2.1.2_, the factory bean has additional constructors, taking a `CleanupConfig` object that has properties to allow you to control whether the `cleanUp()` method is called during `start()`, `stop()`, or neither.
==== Kafka Streams Example
Putting it all together: