shashankhs11 commented on code in PR #20408:
URL: https://github.com/apache/kafka/pull/20408#discussion_r2305573672
##########
docs/streams/developer-guide/datatypes.html:
##########
@@ -163,6 +164,72 @@ <h3>JSON<a class="headerlink" href="#json"
title="Permalink to this headline"></
<p>As shown in the example, you can use JSONSerdes inner classes <code
class="docutils literal"><span
class="pre">Serdes.serdeFrom(<serializerInstance>,
<deserializerInstance>)</span></code> to construct JSON compatible
serializers and deserializers.
</p>
</div>
+ <div class="section" id="window-serdes">
+ <h3>Window Serdes<a class="headerlink" href="#window-serdes"
title="Permalink to this headline"></a></h3>
+ <p>Apache Kafka Streams includes serde implementations for windowed
keys in
+ its <code class="docutils literal"><span
class="pre">kafka-streams</span></code> Maven artifact:</p>
+ <pre class="line-numbers"><code class="language-xml"><dependency>
+ <groupId>org.apache.kafka</groupId>
+ <artifactId>kafka-streams</artifactId>
+ <version>{{fullDotVersion}}</version>
+</dependency></code></pre>
+ <p>This artifact provides the following windowed serde implementations
under the package <a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/streams/src/main/java/org/apache/kafka/streams/kstream">org.apache.kafka.streams.kstream</a>:</p>
+ <table border="1" class="docutils">
+ <colgroup>
+ <col width="17%" />
+ <col width="83%" />
+ </colgroup>
+ <thead valign="bottom">
+ <tr class="row-odd"><th class="head">Data type</th>
+ <th class="head">Serde</th>
+ </tr>
+ </thead>
+ <tbody valign="top">
+ <tr class="row-even"><td>Windowed<T> (Time Windows)</td>
+ <td><code class="docutils literal"><span class="pre">new
WindowedSerdes.TimeWindowedSerde<>(innerSerde, windowSize)</span></code>,
<code class="docutils literal"><span
class="pre">WindowedSerdes.timeWindowedSerdeFrom(Class<T> type, long
windowSize)</span></code></td>
+ </tr>
+ <tr class="row-odd"><td>Windowed<T> (Session Windows)</td>
+ <td><code class="docutils literal"><span class="pre">new
WindowedSerdes.SessionWindowedSerde<>(innerSerde)</span></code>, <code
class="docutils literal"><span
class="pre">WindowedSerdes.sessionWindowedSerdeFrom(Class<T>
type)</span></code></td>
+ </tr>
+ <tr class="row-even"><td>TimeWindowedSerializer<T></td>
+ <td><code class="docutils literal"><span class="pre">new
TimeWindowedSerializer<>(innerSerializer)</span></code></td>
+ </tr>
+ <tr class="row-odd"><td>TimeWindowedDeserializer<T></td>
+ <td><code class="docutils literal"><span class="pre">new
TimeWindowedDeserializer<>(innerDeserializer,
windowSize)</span></code></td>
+ </tr>
+ <tr class="row-even"><td>SessionWindowedSerializer<T></td>
+ <td><code class="docutils literal"><span class="pre">new
SessionWindowedSerializer<>(innerSerializer)</span></code></td>
+ </tr>
+ <tr class="row-odd"><td>SessionWindowedDeserializer<T></td>
+ <td><code class="docutils literal"><span class="pre">new
SessionWindowedDeserializer<>(innerDeserializer)</span></code></td>
+ </tr>
+ </tbody>
+ </table>
+ <h4>Migration from Deprecated Configs</h4>
Review Comment:
addressed in a918948! Here is a quick preview of the changes
<img width="813" height="729" alt="image"
src="https://github.com/user-attachments/assets/9f44ce73-ef65-4873-acfd-54f85500f0e3"
/>
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]