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 fd3e7d9f MINOR: fix for example implementation of how to add a new
header to the record (#297)
fd3e7d9f is described below
commit fd3e7d9f092920c2e2a881fe5cfda0a6a98e436d
Author: Sanjay Ravikumar <[email protected]>
AuthorDate: Mon Jan 23 20:05:42 2023 -0800
MINOR: fix for example implementation of how to add a new header to the
record (#297)
---
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 f28a0d5e..926533db 100644
--- a/26/streams/developer-guide/processor-api.html
+++ b/26/streams/developer-guide/processor-api.html
@@ -392,7 +392,7 @@
<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 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="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="s">key</span><span
class="o">,</span> <span class="n">value</span><span class="o">.</span><span
class="na">getBytes</span><span class="o">());</span>
<span class="o">}</span></code></pre></div>
</div>
<div class="section" id="connecting-processors-and-state-stores">
