This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/kafka-site.git
The following commit(s) were added to refs/heads/asf-site by this push:
new a634bee5 MINOR: fix for extra line break in streams processor API
documentation (#296)
a634bee5 is described below
commit a634bee573d2ddf34c23cf362e48c1e87aaa1c8b
Author: Sanjay Ravikumar <[email protected]>
AuthorDate: Mon Jan 23 19:54:24 2023 -0800
MINOR: fix for extra line break in streams processor API documentation
(#296)
---
26/streams/developer-guide/processor-api.html | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/26/streams/developer-guide/processor-api.html
b/26/streams/developer-guide/processor-api.html
index 897634cd..f28a0d5e 100644
--- a/26/streams/developer-guide/processor-api.html
+++ b/26/streams/developer-guide/processor-api.html
@@ -88,7 +88,7 @@
<code class="docutils literal"><span
class="pre">init()</span></code> on it again after <code class="docutils
literal"><span class="pre">close()</span></code>.</p>
<p>When records are forwarded via downstream processors they also
get a timestamp assigned. There are two different default behaviors:
(1) If <code class="docutils literal"><span
class="pre">#forward()</span></code> is called within <code class="docutils
literal"><span class="pre">#process()</span></code> the output record inherits
the input record timestamp.
- (2) If <code class="docutils literal"><span
class="pre">#forward()</span></code> is called within <code class="docutils
literal"><span class="pre">punctuate()</span></code></p> the output record
inherits the current punctuation timestamp (either current 'stream time' or
system wall-clock time).
+ (2) If <code class="docutils literal"><span
class="pre">#forward()</span></code> is called within <code class="docutils
literal"><span class="pre">punctuate()</span></code> the output record inherits
the current punctuation timestamp (either current 'stream time' or system
wall-clock time).
Note, that <code class="docutils literal"><span
class="pre">#forward()</span></code> also allows to change the default behavior
by passing a custom timestamp for the output record.</p>
<p>Specifically, <code class="docutils literal"><span
class="pre">ProcessorContext#schedule()</span></code> accepts a user <code
class="docutils literal"><span class="pre">Punctuator</span></code> callback
interface, which triggers its <code class="docutils literal"><span
class="pre">punctuate()</span></code>
API method periodically based on the <code class="docutils
literal"><span class="pre">PunctuationType</span></code>. The <code
class="docutils literal"><span class="pre">PunctuationType</span></code>
determines what notion of time is used
