You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ab...@apache.org on 2024/01/02 18:47:08 UTC
(kafka) branch 3.7 updated: KAFKA-15215: docs for KIP-954 (#14949)
This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a commit to branch 3.7
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/3.7 by this push:
new 605b2d5404c KAFKA-15215: docs for KIP-954 (#14949)
605b2d5404c is described below
commit 605b2d5404c300f1632434d99f0e1e09d7999124
Author: Almog Gavra <al...@gmail.com>
AuthorDate: Tue Jan 2 10:44:24 2024 -0800
KAFKA-15215: docs for KIP-954 (#14949)
Upgrade guide and config docs for KIP-954, adding the new dsl.store.suppliers config for default store configuration
Reviewers: Anna Sophie Blee-Goldman <ab...@apache.org>, Matthias Sax <mj...@apache.org>
---
docs/streams/developer-guide/config-streams.html | 17 +++++++++++++++++
docs/streams/upgrade-guide.html | 12 +++++++++++-
2 files changed, 28 insertions(+), 1 deletion(-)
diff --git a/docs/streams/developer-guide/config-streams.html b/docs/streams/developer-guide/config-streams.html
index 7be637dc69d..70dd5ff0c24 100644
--- a/docs/streams/developer-guide/config-streams.html
+++ b/docs/streams/developer-guide/config-streams.html
@@ -310,6 +310,23 @@ streamsSettings.put(StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG, 1);</code></pre>
<td colspan="2">Default serializer/deserializer for the inner class of windowed values, implementing the <code class="docutils literal"><span class="pre">Serde</span></code> interface.</td>
<td>null</td>
</tr>
+ <tr class="row-even"><td>default.dsl.store</td>
+ <td>Low</td>
+ <td colspan="2">
+ [DEPRECATED] The default state store type used by DSL operators. Deprecated in
+ favor of <code>dsl.store.suppliers.class</code>
+ </td>
+ <td><code>ROCKS_DB</code></td>
+ </tr>
+ <tr class="row-odd"><td>dsl.store.suppliers.class</td>
+ <td>Low</td>
+ <td colspan="2">
+ Defines a default state store implementation to be used by any stateful DSL operator
+ that has not explicitly configured the store implementation type. Must implement
+ the <code>org.apache.kafka.streams.state.DslStoreSuppliers</code> interface.
+ </td>
+ <td><code>BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers</code></td>
+ </tr>
<tr class="row-even"><td>max.task.idle.ms</td>
<td>Medium</td>
<td colspan="2">
diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html
index bc7c0b020ab..4d838403ea7 100644
--- a/docs/streams/upgrade-guide.html
+++ b/docs/streams/upgrade-guide.html
@@ -209,7 +209,17 @@
</pre>
</p>
- <h3><a id="streams_api_changes_370" href="#streams_api_changes_370">Streams API changes in 3.7.0</a></h3>
+
+ <p>
+ The <code>default.dsl.store</code> config was deprecated in favor of the new
+ <code>dsl.store.suppliers.class</code> config to allow for custom state store
+ implementations to be configured as the default.
+
+ If you currently specify <code>default.dsl.store=ROCKS_DB</code> or <code>default.dsl.store=IN_MEMORY</code> replace those
+ configurations with <code>dsl.store.suppliers.class=BuiltInDslStoreSuppliers.RocksDBDslStoreSuppliers.class</code> and
+ <code>dsl.stores.suppliers.class=BuiltInDslStoreSuppliers.InMemoryDslStoreSuppliers.class</code> respectively
+ </p>
+
<p>
A new configuration option <code>balance_subtopology</code> for <code>rack.aware.assignment.strategy</code> was introduced in 3.7 release.
For more information, including how it can be enabled and further configured, see the <a href="/{{version}}/documentation/streams/developer-guide/config-streams.html#rack-aware-assignment-strategy"><b>Kafka Streams Developer Guide</b></a>.