This is an automated email from the ASF dual-hosted git repository.
bbejeck 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 5092b26 MINOR: update docs JSON serde links (#6465)
5092b26 is described below
commit 5092b26393de731e8f826fde86b7ea97c9aaba35
Author: Victoria Bialas <londoncall...@users.noreply.github.com>
AuthorDate: Tue Mar 19 15:01:59 2019 -0700
MINOR: update docs JSON serde links (#6465)
Reviewers: Joel Mamill <j...@confluent.io>, Matthias J. Sax
<mj...@apache.org>
---
docs/streams/developer-guide/datatypes.html | 23 ++++++++++-------------
1 file changed, 10 insertions(+), 13 deletions(-)
diff --git a/docs/streams/developer-guide/datatypes.html
b/docs/streams/developer-guide/datatypes.html
index 6c7869c..ca17c0b 100644
--- a/docs/streams/developer-guide/datatypes.html
+++ b/docs/streams/developer-guide/datatypes.html
@@ -112,7 +112,7 @@
<span class="nt"></dependency></span>
</pre></div>
</div>
- <p>This artifact provides the following serde implementations under
the package <a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/clients/src/main/java/org/apache/kafka/common/serialization";>org.apache.kafka.common.serialization</a>,
which you can leverage when e.g., defining default serializers in your Streams
configuration.</p>
+ <p>This artifact provides the following serde implementations under
the package <a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/clients/src/main/java/org/apache/kafka/common/serialization";>org.apache.kafka.common.serialization</a>,
which you can leverage when e.g., defining default serializers in your Streams
configuration.</p>
<table border="1" class="docutils">
<colgroup>
<col width="17%" />
@@ -149,20 +149,17 @@
</table>
<div class="admonition tip">
<p><b>Tip</b></p>
- <p class="last"><a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/clients/src/main/java/org/apache/kafka/common/utils/Bytes.java";>Bytes</a>
is a wrapper for Java’s <code class="docutils literal"><span
class="pre">byte[]</span></code> (byte array) that supports proper equality and
ordering semantics. You may want to consider using <code class="docutils
literal"><span class="pre">Bytes</span></code> instead of <code class="docutils
literal"><span [...]
+ <p class="last"><a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/clients/src/main/java/org/apache/kafka/common/utils/Bytes.java";>Bytes</a>
is a wrapper for Java’s <code class="docutils literal"><span
class="pre">byte[]</span></code> (byte array) that supports proper equality and
ordering semantics. You may want to consider using <code class="docutils
literal"><span class="pre">Bytes</span></code> instead of <code class="docutils
lit [...]
</div>
</div>
<div class="section" id="json">
<h3>JSON<a class="headerlink" href="#json" title="Permalink to this
headline"></a></h3>
- <p>The code examples of Kafka Streams also include a basic serde
implementation for JSON:</p>
+ <p>The Kafka Streams code examples also include a basic serde
implementation for JSON:</p>
<ul class="simple">
- <li><a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonPOJOSerializer.java";>JsonPOJOSerializer</a></li>
- <li><a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonPOJODeserializer.java";>JsonPOJODeserializer</a></li>
+ <li><a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java#L83";>PageViewTypedDemo</a></li>
</ul>
- <p>You can construct a unified JSON serde from the <code
class="docutils literal"><span class="pre">JsonPOJOSerializer</span></code> and
<code class="docutils literal"><span
class="pre">JsonPOJODeserializer</span></code> via
- <code class="docutils literal"><span
class="pre">Serdes.serdeFrom(<serializerInstance>,</span> <span
class="pre"><deserializerInstance>)</span></code>. The
- <a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java";>PageViewTypedDemo</a>
- example demonstrates how to use this JSON serde.</p>
+ <p>As shown in the example, you can use JSONSerdes inner classes <code
class="docutils literal"><span
class="pre">Serdes.serdeFrom(<serializerInstance>,
<deserializerInstance>)</span></code> to construct JSON compatible
serializers and deserializers.
+ </p>
</div>
<div class="section" id="implementing-custom-serdes">
<span
id="streams-developer-guide-serdes-custom"></span><h2>Implementing custom
SerDes<a class="headerlink" href="#implementing-custom-serdes" title="Permalink
to this headline"></a></h2>
@@ -170,13 +167,13 @@
existing SerDes (see previous section). Typically, your workflow
will be similar to:</p>
<ol class="arabic simple">
<li>Write a <em>serializer</em> for your data type <code
class="docutils literal"><span class="pre">T</span></code> by implementing
- <a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java";>org.apache.kafka.common.serialization.Serializer</a>.</li>
+ <a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java";>org.apache.kafka.common.serialization.Serializer</a>.</li>
<li>Write a <em>deserializer</em> for <code class="docutils
literal"><span class="pre">T</span></code> by implementing
- <a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java";>org.apache.kafka.common.serialization.Deserializer</a>.</li>
+ <a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java";>org.apache.kafka.common.serialization.Deserializer</a>.</li>
<li>Write a <em>serde</em> for <code class="docutils literal"><span
class="pre">T</span></code> by implementing
- <a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/clients/src/main/java/org/apache/kafka/common/serialization/Serde.java";>org.apache.kafka.common.serialization.Serde</a>,
+ <a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/clients/src/main/java/org/apache/kafka/common/serialization/Serde.java";>org.apache.kafka.common.serialization.Serde</a>,
which you either do manually (see existing SerDes in the previous
section) or by leveraging helper functions in
- <a class="reference external"
href="https://github.com/apache/kafka/blob/1.0/clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java";>Serdes</a>
+ <a class="reference external"
href="https://github.com/apache/kafka/blob/{{dotVersion}}/clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java";>Serdes</a>
such as <code class="docutils literal"><span
class="pre">Serdes.serdeFrom(Serializer<T>,
Deserializer<T>)</span></code>.
Note that you will need to implement your own class (that has no
generic types) if you want to use your custom serde in the configuration
provided to <code class="docutils literal"><span
class="pre">KafkaStreams</span></code>.
If your serde class has generic types or you use <code
class="docutils literal"><span
class="pre">Serdes.serdeFrom(Serializer<T>,
Deserializer<T>)</span></code>, you can pass your serde only
