You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sh...@apache.org on 2023/07/16 06:58:45 UTC

[kafka] branch trunk updated: fix typo in streams/dsl-api.html (#14023)

This is an automated email from the ASF dual-hosted git repository.

showuon pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 8afa881a115 fix typo in streams/dsl-api.html (#14023)
8afa881a115 is described below

commit 8afa881a115003aed9e9afe45ae135d9ae86d0c2
Author: Iblis Lin <ib...@apache.org>
AuthorDate: Sun Jul 16 14:58:37 2023 +0800

    fix typo in streams/dsl-api.html (#14023)
    
    Fix typo in docs/streams/dsl-api.html
    
    Reviewers: Luke Chen <sh...@gmail.com>, Divij Vaidya <di...@amazon.com>
---
 docs/streams/developer-guide/dsl-api.html | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/streams/developer-guide/dsl-api.html b/docs/streams/developer-guide/dsl-api.html
index 564f878736d..08bf2ef8cf8 100644
--- a/docs/streams/developer-guide/dsl-api.html
+++ b/docs/streams/developer-guide/dsl-api.html
@@ -1333,7 +1333,7 @@ KTable&lt;Windowed&lt;String&gt;, Long&gt; sessionzedAggregatedStream = groupedS
 // Java 7 examples
 
 // Aggregating with time-based windowing (here: with 5-minute tumbling windows)
-KTable&lt;Windowed&lt;String&gt;, Long&gt; timeWindowedAggregatedStream = groupedStream..windowedBy(
+KTable&lt;Windowed&lt;String&gt;, Long&gt; timeWindowedAggregatedStream = groupedStream.windowedBy(
   TimeWindows.ofSizeWithNoGrace(Duration.ofMinutes(5)) /* time-based window */)
   .reduce(
     new Reducer&lt;Long&gt;() { /* adder */