From 39eb477f02b189cd40f9594b2537088a2d594b8e Mon Sep 17 00:00:00 2001 From: fml2 <534392+fml2@users.noreply.github.com> Date: Tue, 17 Nov 2020 22:47:23 +0100 Subject: [PATCH 1/2] doc: Described the types of the stores used This is related to KAFKA-10722 --- docs/streams/developer-guide/dsl-api.html | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index 33648f39b1961..d4524869951bf 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -870,6 +870,12 @@

Stateful transformations depend on state for processing inputs and producing outputs and require a state store associated with the stream processor. For example, in aggregating operations, a windowing state store is used to collect the latest aggregation results per window. In join operations, a windowing state store is used to collect all of the records received so far within the defined window boundary.

+

Note: Following store types are used regardless of the possibly specified type (via the parameter materialized): +

Note, that state stores are fault-tolerant. In case of failure, Kafka Streams guarantees to fully restore all state stores prior to resuming the processing. See Fault Tolerance for further information.

From faa5c525f3a1284f6c0c1204d37b3be16ba53907 Mon Sep 17 00:00:00 2001 From: fml2 <534392+fml2@users.noreply.github.com> Date: Wed, 18 Nov 2020 09:09:35 +0100 Subject: [PATCH 2/2] docs: Improved wording --- docs/streams/developer-guide/dsl-api.html | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html index d4524869951bf..8304c7b76e427 100644 --- a/docs/streams/developer-guide/dsl-api.html +++ b/docs/streams/developer-guide/dsl-api.html @@ -872,8 +872,8 @@

materialized):

Note, that state stores are fault-tolerant.