Skip to content

Commit 33ffe06

Browse files
MINOR: added information about KIP-1034, KIP-1153, KIP-1195, and KIP-1230 to the upgrade guide. (#20779)
Updates Kafka Streams upgrade guide for 4.2.0 release. Reviewers: Matthias J. Sax <[email protected]>
1 parent 55764f8 commit 33ffe06

File tree

1 file changed

+29
-0
lines changed

1 file changed

+29
-0
lines changed

docs/streams/upgrade-guide.html

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,35 @@ <h3 class="anchor-heading"><a id="streams_notable_changes" class="anchor-link"><
108108

109109
<p>Since 2.6.0 release, Kafka Streams depends on a RocksDB version that requires MacOS 10.14 or higher.</p>
110110

111+
<h3><a id="streams_api_changes_420" href="#streams_api_changes_420">Streams API changes in 4.2.0</a></h3>
112+
113+
<p>
114+
Kafka Streams now supports Dead Letter Queue (DLQ).
115+
A new config <code>errors.deadletterqueue.topic.name</code> allows to specify the name of the DLQ topic. When set and <code>DefaultProductionExceptionHandler</code> is used, records that cause exceptions will be forwarded to the DLQ topic.
116+
If a custom exception handler is used, it is up to the custom handler to build DLQ records to send, hence, depending on the implementation, the <code>errors.deadletterqueue.topic.name</code> configuration may be ignored.
117+
118+
<code>org.apache.kafka.streams.errors.ProductionExceptionHandler$ProductionExceptionHandlerResponse</code> is deprecated and replaced by <code>org.apache.kafka.streams.errors.ProductionExceptionHandler$Response</code>.
119+
Methods <code>handle</code> and <code>handleSerializationException</code> in <code>org.apache.kafka.streams.errors.ProductionExceptionHandler</code> are deprecated and replaced by <code>handleError</code> and <code>handleSerializationError</code> respectively in order to use the new <code>Response</code> class.
120+
More details can be found in <a href="https://cwiki.apache.org/confluence/x/HwviEQ">KIP-1034</a>.
121+
</p>
122+
123+
<p>
124+
We introduce a new <code>org.apache.kafka.streams.CloseOptions</code> class which replaces the existing <code>org.apache.kafka.streams.KafkaStreams$CloseOptions</code>.
125+
The latter is deprecated and will be removed in the next major release.
126+
<code>CloseOptions</code> class allows to specify close timeout and group membership operation - whether the consumer needs to leave the group or remain in the group.
127+
More details can be found in <a href="https://cwiki.apache.org/confluence/x/QAq9F">KIP-1153</a>.
128+
</p>
129+
130+
<p>
131+
Kafka Streams now allows to enable state store directories created by Kafka Streams to have write access for the OS group, via the newly added config <code>allow.os.group.write.access</code>.
132+
More details can be found in <a href="https://cwiki.apache.org/confluence/x/jgl3Fw">KIP-1230</a>.
133+
</p>
134+
135+
<p>
136+
<code>org.apache.kafka.streams.errors.BrokerNotFoundException</code> was deprecated and will be removed in the next major release.
137+
More details can be found in <a href="https://cwiki.apache.org/confluence/x/8AxJFg">KIP-1195</a>.
138+
</p>
139+
111140
<h3><a id="streams_api_changes_410" href="#streams_api_changes_410">Streams API changes in 4.1.0</a></h3>
112141

113142
<p><b>Note:</b> Kafka Streams 4.1.0 contains a critical memory leak bug (<a href="https://issues.apache.org/jira/browse/KAFKA-19748">KAFKA-19748</a>) that affects users of range scans and certain DSL operators (session windows, sliding windows, stream-stream joins, foreign-key joins). Users running Kafka Streams should consider upgrading directly to 4.1.1 when available.</p>

0 commit comments

Comments
 (0)