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<Windowed<String>, Long> sessionzedAggregatedStream = groupedS
// Java 7 examples
// Aggregating with time-based windowing (here: with 5-minute tumbling windows)
-KTable<Windowed<String>, Long> timeWindowedAggregatedStream = groupedStream..windowedBy(
+KTable<Windowed<String>, Long> timeWindowedAggregatedStream = groupedStream.windowedBy(
TimeWindows.ofSizeWithNoGrace(Duration.ofMinutes(5)) /* time-based window */)
.reduce(
new Reducer<Long>() { /* adder */