kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: update docs with regard to improved resilience of Kafka Streams (#4380)
Date Mon, 22 Jan 2018 22:37:22 GMT
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 9ef883e  MINOR: update docs with regard to improved resilience of Kafka Streams (#4380)
9ef883e is described below

commit 9ef883e62fc10e04105278d3cb8d7076e3ebc941
Author: Matthias J. Sax <mjsax@apache.org>
AuthorDate: Mon Jan 22 14:37:19 2018 -0800

    MINOR: update docs with regard to improved resilience of Kafka Streams (#4380)
    
    Reviewers: Guozhang Wang <wangguoz@gmail.com>, Joel Hamill, Damian Guy <damian.guy@gmail.com>,
Bill Bejeck <bill@confluent.io>
---
 docs/streams/developer-guide/config-streams.html | 2 +-
 docs/upgrade.html                                | 5 +++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/docs/streams/developer-guide/config-streams.html b/docs/streams/developer-guide/config-streams.html
index 256cc18..8fbb6d5 100644
--- a/docs/streams/developer-guide/config-streams.html
+++ b/docs/streams/developer-guide/config-streams.html
@@ -539,7 +539,7 @@
 <span class="n">streamsSettings</span><span class="o">.</span><span
class="na">put</span><span class="o">(</span><span class="s">&quot;producer.PARAMETER_NAME&quot;</span><span
class="o">,</span> <span class="s">&quot;producer-value&quot;</span><span
class="o">);</span>
 <span class="c1">// alternatively, you can use</span>
 <span class="n">streamsSettings</span><span class="o">.</span><span
class="na">put</span><span class="o">(</span><span class="n">StreamsConfig</span><span
class="o">.</span><span class="na">consumerPrefix</span><span class="o">(</span><span
class="s">&quot;PARAMETER_NAME&quot;</span><span class="o">),</span>
<span class="s">&quot;consumer-value&quot;</span><span class="o">);</span>
-<span class="n">streamsSettings</span><span class="o">.</span><span
class="na">put</span><span class="o">(</span><span class="n">StremasConfig</span><span
class="o">.</span><span class="na">producerConfig</span><span class="o">(</span><span
class="s">&quot;PARAMETER_NAME&quot;</span><span class="o">),</span>
<span class="s">&quot;producer-value&quot;</span><span class="o">);</span>
+<span class="n">streamsSettings</span><span class="o">.</span><span
class="na">put</span><span class="o">(</span><span class="n">StreamsConfig</span><span
class="o">.</span><span class="na">producerPrefix</span><span class="o">(</span><span
class="s">&quot;PARAMETER_NAME&quot;</span><span class="o">),</span>
<span class="s">&quot;producer-value&quot;</span><span class="o">);</span>
 </pre></div>
           </div>
         </div>
diff --git a/docs/upgrade.html b/docs/upgrade.html
index 6140059..69e0e7c 100644
--- a/docs/upgrade.html
+++ b/docs/upgrade.html
@@ -67,6 +67,11 @@
         can now choose the logging back-end by including the appropriate slf4j module (slf4j-log4j12,
logback, etc.). The release
         tarball still includes log4j and slf4j-log4j12.</li>
     <li><a href="https://cwiki.apache.org/confluence/x/uaBzB">KIP-225</a>
changed the metric "records.lag" to use tags for topic and partition. The original version
with the name format "{topic}-{partition}.records-lag" is deprecated and will be removed in
2.0.0.</li>
+    <li>Kafka Streams is more robust against broker communication errors. Instead of
stopping the Kafka Streams client with a fatal exception,
+	Kafka Streams tries to self-heal and reconnect to the cluster. Using the new <code>AdminClient</code>
you have better control of how often
+	Kafka Streams retries and can <a href="/{{version}}/documentation/streams/developer-guide/config-streams">configure<a/>
+	fine-grained timeouts (instead of hard coded retries as in older version).</li>
+    <li>Kafka Streams rebalance time was reduced further making Kafka Streams more
responsive.</li>
 </ul>
 
 <h5><a id="upgrade_110_new_protocols" href="#upgrade_110_new_protocols">New Protocol
Versions</a></h5>

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.

Mime
View raw message