This is an automated email from the ASF dual-hosted git repository.
guozhang 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 2d87763 MINOR: web docs fixes on message header (#5381)
2d87763 is described below
commit 2d877631cde81bd0fdc42bd5bff0c31e5820d623
Author: Guozhang Wang <[email protected]>
AuthorDate: Tue Jul 17 17:31:32 2018 -0700
MINOR: web docs fixes on message header (#5381)
Reviewers: Matthias J. Sax <[email protected]>
---
docs/streams/developer-guide/processor-api.html | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/streams/developer-guide/processor-api.html
b/docs/streams/developer-guide/processor-api.html
index e07efb1..cb45cd9 100644
--- a/docs/streams/developer-guide/processor-api.html
+++ b/docs/streams/developer-guide/processor-api.html
@@ -354,7 +354,7 @@
</div>
<div class="section" id="accessing-processor-context">
<h2><a class="toc-backref" href="#id10">Accessing Processor
Context</a><a class="headerlink" href="#accessing-processor-context"
title="Permalink to this headline"></a></h2>
- <p>As we have mentioned in
<href=#defining-a-stream-processor>Defining a Stream Processor<\href>, a
<code>ProcessorContext</code> control the processing workflow, such as
scheduling a punctuation function, and committing the current processed
state.</p>
+ <p>As we have mentioned in the <a
href=#defining-a-stream-processor>Defining a Stream Processor</a> section, a
<code>ProcessorContext</code> control the processing workflow, such as
scheduling a punctuation function, and committing the current processed
state.</p>
<p>This object can also be used to access the metadata related
with the application like
<code class="docutils literal"><span
class="pre">applicationId</span></code>, <code class="docutils literal"><span
class="pre">taskId</span></code>,
and <code class="docutils literal"><span
class="pre">stateDir</span></code>, and also record related metadata as <code
class="docutils literal"><span class="pre">topic</span></code>,
@@ -363,7 +363,7 @@
<p>Here is an example implementation of how to add a new header to
the record:</p>
<div class="highlight-java"><div
class="highlight"><pre><span></span><span class="n">public void process(String
key, String value) {</span>
- <span class="c1">// add a heaeder to the elements</span>
+ <span class="c1">// add a header to the elements</span>
<span class="n">context()</span><span class="o">.</span><span
class="na">headers</span><span class="o">()</span><span class="o">.</span><span
class="na">add</span><span class="o">.</span><span class="o">(</span><span
class="s">"key"</span><span class="o">,</span> <span
class="s">"key"</span>
<span class="o">}</span>
</pre></div>
