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 ebdefaa Update Webpage for 2.2.0 release (#192)
ebdefaa is described below
commit ebdefaa2e3a280c73718422a6e1f9be140f19ce2
Author: Matthias J. Sax <[email protected]>
AuthorDate: Tue Mar 26 09:58:32 2019 -0700
Update Webpage for 2.2.0 release (#192)
Reviewers: Gwen Shapira <[email protected]>
---
22/streams/developer-guide/datatypes.html | 4 +--
22/streams/upgrade-guide.html | 2 ++
22/upgrade.html | 42 ++++++++++++++++++++++++++
documentation.html | 2 +-
downloads.html | 49 ++++++++++++++++++++++++++++++-
intro.html | 2 +-
protocol.html | 2 +-
quickstart.html | 2 +-
uses.html | 2 +-
9 files changed, 99 insertions(+), 8 deletions(-)
diff --git a/22/streams/developer-guide/datatypes.html
b/22/streams/developer-guide/datatypes.html
index c0b7582..84868ba 100644
--- a/22/streams/developer-guide/datatypes.html
+++ b/22/streams/developer-guide/datatypes.html
@@ -1,4 +1,4 @@
-2.2<!--
+<!--
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
@@ -149,7 +149,7 @@
</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">
diff --git a/22/streams/upgrade-guide.html b/22/streams/upgrade-guide.html
index d2e4a2e..660c4af 100644
--- a/22/streams/upgrade-guide.html
+++ b/22/streams/upgrade-guide.html
@@ -58,6 +58,8 @@
For Kafka Streams 0.10.0, broker version 0.10.0 or higher is required.
</p>
+ <p>Since 2.2.0 release, Kafka Streams depends on a RocksDBs version that
requires MacOS 10.13 or higher.</p>
+
<p>
Another important thing to keep in mind: in deprecated
<code>KStreamBuilder</code> class, when a <code>KTable</code> is created from a
source topic via <code>KStreamBuilder.table()</code>, its materialized state
store
will reuse the source topic as its changelog topic for restoring, and
will disable logging to avoid appending new updates to the source topic; in the
<code>StreamsBuilder</code> class introduced in 1.0, this behavior was changed
diff --git a/22/upgrade.html b/22/upgrade.html
index 2ba7fd3..1828ab7 100644
--- a/22/upgrade.html
+++ b/22/upgrade.html
@@ -20,6 +20,47 @@
<script id="upgrade-template" type="text/x-handlebars-template">
<h4><a id="upgrade_2_2_0" href="#upgrade_2_2_0">Upgrading from 0.8.x, 0.9.x,
0.10.0.x, 0.10.1.x, 0.10.2.x, 0.11.0.x, 1.0.x, 1.1.x, 2.0.x or 2.1.x to
2.2.0</a></h4>
+
+<p><b>If you are upgrading from a version prior to 2.1.x, please see the note
below about the change to the schema used to store consumer offsets.
+ Once you have changed the inter.broker.protocol.version to the latest
version, it will not be possible to downgrade to a version prior to 2.1.</b></p>
+
+<p><b>For a rolling upgrade:</b></p>
+
+<ol>
+ <li> Update server.properties on all brokers and add the following
properties. CURRENT_KAFKA_VERSION refers to the version you
+ are upgrading from. CURRENT_MESSAGE_FORMAT_VERSION refers to the
message format version currently in use. If you have previously
+ overridden the message format version, you should keep its current
value. Alternatively, if you are upgrading from a version prior
+ to 0.11.0.x, then CURRENT_MESSAGE_FORMAT_VERSION should be set to
match CURRENT_KAFKA_VERSION.
+ <ul>
+ <li>inter.broker.protocol.version=CURRENT_KAFKA_VERSION (e.g.
0.8.2, 0.9.0, 0.10.0, 0.10.1, 0.10.2, 0.11.0, 1.0, 1.1).</li>
+ <li>log.message.format.version=CURRENT_MESSAGE_FORMAT_VERSION
(See <a href="#upgrade_10_performance_impact">potential performance impact
+ following the upgrade</a> for the details on what this
configuration does.)</li>
+ </ul>
+ If you are upgrading from 0.11.0.x, 1.0.x, 1.1.x, or 2.0.x and you
have not overridden the message format, then you only need to override
+ the inter-broker protocol version.
+ <ul>
+ <li>inter.broker.protocol.version=CURRENT_KAFKA_VERSION (0.11.0,
1.0, 1.1, 2.0).</li>
+ </ul>
+ </li>
+ <li> Upgrade the brokers one at a time: shut down the broker, update the
code, and restart it. Once you have done so, the
+ brokers will be running the latest version and you can verify that the
cluster's behavior and performance meets expectations.
+ It is still possible to downgrade at this point if there are any
problems.
+ </li>
+ <li> Once the cluster's behavior and performance has been verified, bump
the protocol version by editing
+ <code>inter.broker.protocol.version</code> and setting it to 2.2.
+ </li>
+ <li> Restart the brokers one by one for the new protocol version to take
effect. Once the brokers begin using the latest
+ protocol version, it will no longer be possible to downgrade the
cluster to an older version.
+ </li>
+ <li> If you have overridden the message format version as instructed
above, then you need to do one more rolling restart to
+ upgrade it to its latest version. Once all (or most) consumers have
been upgraded to 0.11.0 or later,
+ change log.message.format.version to 2.2 on each broker and restart
them one by one. Note that the older Scala clients,
+ which are no longer maintained, do not support the message format
introduced in 0.11, so to avoid conversion costs
+ (or to take advantage of <a
href="#upgrade_11_exactly_once_semantics">exactly once semantics</a>),
+ the newer Java clients must be used.
+ </li>
+</ol>
+
<h5><a id="upgrade_220_notable" href="#upgrade_220_notable">Notable changes in
2.2.0</a></h5>
<ul>
<li>The default consumer group id has been changed from the empty string
(<code>""</code>) to <code>null</code>. Consumers who use the new default group
id will not be able to subscribe to topics,
@@ -28,6 +69,7 @@
<a
href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-289%3A+Improve+the+default+group+id+behavior+in+KafkaConsumer">KIP-289</a>.</li>
<li>The <code>bin/kafka-topics.sh</code> command line tool is now able to
connect directly to brokers with <code>--bootstrap-server</code> instead of
zookeeper. The old <code>--zookeeper</code>
option is still available for now. Please read <a
href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-377%3A+TopicCommand+to+use+AdminClient">KIP-377</a>
for more information.</li>
+ <li>Kafka Streams depends on a newer version of RocksDBs that requires
MacOS 10.13 or higher.</li>
</ul>
<h4><a id="upgrade_2_1_0" href="#upgrade_2_1_0">Upgrading from 0.8.x, 0.9.x,
0.10.0.x, 0.10.1.x, 0.10.2.x, 0.11.0.x, 1.0.x, 1.1.x, or 2.0.0 to 2.1.0</a></h4>
diff --git a/documentation.html b/documentation.html
index f71e8a0..0af95d1 100644
--- a/documentation.html
+++ b/documentation.html
@@ -1,2 +1,2 @@
<!-- should always link the the latest release's documentation -->
-<!--#include virtual="21/documentation.html" -->
+<!--#include virtual="22/documentation.html" -->
diff --git a/downloads.html b/downloads.html
index 78b2de8..420c52b 100644
--- a/downloads.html
+++ b/downloads.html
@@ -5,12 +5,59 @@
<div class="right">
<h1>Download</h1>
- <p>2.1.1 is the latest release. The current stable version is 2.1.1.</p>
+ <p>2.2.0 is the latest release. The current stable version is 2.2.0.</p>
<p>
You can verify your download by following these <a
href="https://www.apache.org/info/verification.html">procedures</a> and using
these <a href="https://www.apache.org/dist/kafka/KEYS">KEYS</a>.
</p>
+ <span id="2.2.0"></span>
+ <h3 class="download-version">2.2.0<a href="#2.2.0"><i class="fas fa-link "
style="color:#053ce2"></i></a></h3>
+ <ul>
+ <li>
+ Released Mar 22, 2019
+ </li>
+ <li>
+ <a
href="https://www.apache.org/dist/kafka/2.2.0/RELEASE_NOTES.html">Release
Notes</a>
+ </li>
+ <li>
+ Source download: <a
href="https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.0/kafka-2.2.0-src.tgz">kafka-2.2.0-src.tgz</a>
(<a
href="https://www.apache.org/dist/kafka/2.2.0/kafka-2.2.0-src.tgz.asc">asc</a>,
<a
href="https://www.apache.org/dist/kafka/2.2.0/kafka-2.2.0-src.tgz.sha512">sha512</a>)
+ </li>
+ <li>
+ Binary downloads:
+ <ul>
+ <li>Scala 2.11 - <a
href="https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.0/kafka_2.11-2.2.0.tgz">kafka_2.11-2.2.0.tgz</a>
(<a
href="https://www.apache.org/dist/kafka/2.2.0/kafka_2.11-2.2.0.tgz.asc">asc</a>,
<a
href="https://www.apache.org/dist/kafka/2.2.0/kafka_2.11-2.2.0.tgz.sha512">sha512</a>)</li>
+ <li>Scala 2.12 - <a
href="https://www.apache.org/dyn/closer.cgi?path=/kafka/2.2.0/kafka_2.12-2.2.0.tgz">kafka_2.12-2.2.0.tgz</a>
(<a
href="https://www.apache.org/dist/kafka/2.2.0/kafka_2.12-2.2.0.tgz.asc">asc</a>,
<a
href="https://www.apache.org/dist/kafka/2.2.0/kafka_2.12-2.2.0.tgz.sha512">sha512</a>)</li>
+ </ul>
+ We build for multiple versions of Scala. This only matters if
you are using Scala and you want a version built for the same Scala version you
use. Otherwise any version should work (2.12 is recommended).
+ </li>
+ </ul>
+
+ <p>
+ Kafka 2.2.0 includes a number of significant new features. Here is
a summary of some notable changes:
+ </p>
+
+ <ul>
+ <li>Added SSL support for custom principal name</li>
+ <li>Allow SASL connections to periodically re-authenticate</li>
+ <li>Command line tool <code>bin/kafka-topics.sh</code> adds
AdminClient support</li>
+ <li>Improved consumer group management: default
<code>group.id</code> is <code>null</code> instead of empty string</li>
+ <li>API improvement:
+ <ul>
+ <li>Producer: introduce <code>close(Duration)</code></li>
+ <li>AdminClient: introduce <code>close(Duration)</code></li>
+ <li>Kafka Streams: new <code>flatTransform()</code> operator in
Streams DSL</li>
+ <li>KafkaStreams (and other classed) now implement
<code>AutoClosable</code> to support try-with-resource</li>
+ <li>New Serdes and default method implementations</li>
+ <ul>
+ </li>
+ <li>Kafka Streams exposed internal <code>client.id</code> via
<code>ThreadMetadata</code></li>
+ <li>Metric improvements: All <code>-min</code>, <code>-avg</code>
and <code>-max</code> metrics will now output <code>NaN</code> as default
value</li>
+ </ul>
+ <p>
+ For more information, please read the detailed <a
href="https://www.apache.org/dist/kafka/2.2.0/RELEASE_NOTES.html">Release
Notes</a>.
+ </p>
+
<span id="2.1.1"></span>
<h3 class="download-version">2.1.1<a href="#2.1.1"><i class="fas fa-link "
style="color:#053ce2"></i></a></h3>
<ul>
diff --git a/intro.html b/intro.html
index 6a852ea..ab71a3c 100644
--- a/intro.html
+++ b/intro.html
@@ -5,7 +5,7 @@
<div class="right">
<h1>Introduction</h1>
<!-- should always link the the latest release's documentation -->
- <!--#include virtual="21/introduction.html" -->
+ <!--#include virtual="22/introduction.html" -->
<!--#include virtual="includes/_footer.htm" -->
diff --git a/protocol.html b/protocol.html
index 1d15fcd..cdfb66d 100644
--- a/protocol.html
+++ b/protocol.html
@@ -1,2 +1,2 @@
<!-- should always link the the latest release's documentation -->
-<!--#include virtual="21/protocol.html" -->
+<!--#include virtual="22/protocol.html" -->
diff --git a/quickstart.html b/quickstart.html
index d3b0f3f..e7a0f1f 100644
--- a/quickstart.html
+++ b/quickstart.html
@@ -5,7 +5,7 @@
<div class="right">
<h1>Quickstart</h1>
<!-- should always link the the latest release's documentation -->
- <!--#include virtual="21/quickstart.html" -->
+ <!--#include virtual="22/quickstart.html" -->
<!--#include virtual="includes/_footer.htm" -->
<script>
// Show selected style on nav item
diff --git a/uses.html b/uses.html
index fe86209..fa07951 100644
--- a/uses.html
+++ b/uses.html
@@ -6,7 +6,7 @@
<h1>Use cases</h1>
<!-- should always link the the latest release's documentation -->
-<!--#include virtual="21/uses.html" -->
+<!--#include virtual="22/uses.html" -->
<!--#include virtual="includes/_footer.htm" -->