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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org