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 a9bf948 MINOR: Fix for typos in processor-api.html (#6961)
a9bf948 is described below
commit a9bf9487dd84c8a874f5a71b2557b57801308249
Author: Sergey Prokofiev <[email protected]>
AuthorDate: Wed Jun 26 00:46:44 2019 +0300
MINOR: Fix for typos in processor-api.html (#6961)
This PR intendent to address some typos in
https://kafka.apache.org/documentation/streams/developer-guide/processor-api.html
page.
Invalid configuration option specified in the example. I've replaced with
closest constant TopicConfig.MIN_IN_SYNC_REPLICAS_CONFIG, since
LogConfig.MinInSyncReplicasProp() requires Scala stuff
Reference to LogConfig seems to be obsolete, I believe I've moved it to
correct line
Apostrophe displayed incorrectly
Reviewers: John Roesler <[email protected]>, Bill Bejeck
<[email protected]>
---
docs/streams/developer-guide/processor-api.html | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/streams/developer-guide/processor-api.html
b/docs/streams/developer-guide/processor-api.html
index 31c11ed..89d3447 100644
--- a/docs/streams/developer-guide/processor-api.html
+++ b/docs/streams/developer-guide/processor-api.html
@@ -309,7 +309,7 @@
<span
id="streams-developer-guide-state-store-enable-disable-fault-tolerance"></span><h3><a
class="toc-backref" href="#id6">Enable or Disable Fault Tolerance of State
Stores (Store Changelogs)</a><a class="headerlink"
href="#enable-or-disable-fault-tolerance-of-state-stores-store-changelogs"
title="Permalink to this headline"></a></h3>
<p>You can enable or disable fault tolerance for a state store
by enabling or disabling the change logging
of the store through <code class="docutils literal"><span
class="pre">enableLogging()</span></code> and <code class="docutils
literal"><span class="pre">disableLogging()</span></code>.
- You can also fine-tune the associated topic’s
configuration if needed.</p>
+ You can also fine-tune the associated topic’s
configuration if needed.</p>
<p>Example for disabling fault-tolerance:</p>
<div class="highlight-java"><div
class="highlight"><pre><span></span><span class="kn">import</span> <span
class="nn">org.apache.kafka.streams.state.StoreBuilder</span><span
class="o">;</span>
<span class="kn">import</span> <span
class="nn">org.apache.kafka.streams.state.Stores</span><span class="o">;</span>
@@ -326,14 +326,14 @@
<p class="last">If the changelog is disabled then the
attached state store is no longer fault tolerant and it can’t have any <a
class="reference internal"
href="config-streams.html#streams-developer-guide-standby-replicas"><span
class="std std-ref">standby replicas</span></a>.</p>
</div>
<p>Here is an example for enabling fault tolerance, with
additional changelog-topic configuration:
- You can add any log config from <a class="reference
external"
href="https://github.com/apache/kafka/blob/1.0/core/src/main/scala/kafka/log/LogConfig.scala#L61";>kafka.log.LogConfig</a>.
+ You can add any log config from <a class="reference
external"
href="https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/log/LogConfig.scala";>kafka.log.LogConfig</a>.
Unrecognized configs will be ignored.</p>
<div class="highlight-java"><div
class="highlight"><pre><span></span><span class="kn">import</span> <span
class="nn">org.apache.kafka.streams.state.StoreBuilder</span><span
class="o">;</span>
<span class="kn">import</span> <span
class="nn">org.apache.kafka.streams.state.Stores</span><span class="o">;</span>
<span class="n">Map</span><span class="o"><</span><span
class="n">String</span><span class="o">,</span> <span
class="n">String</span><span class="o">></span> <span
class="n">changelogConfig</span> <span class="o">=</span> <span
class="k">new</span> <span class="n">HashMap</span><span class="o">();</span>
<span class="c1">// override min.insync.replicas</span>
-<span class="n">changelogConfig</span><span class="o">.</span><span
class="na">put</span><span class="o">(</span><span
class="s">"min.insyc.replicas"</span><span class="o">,</span> <span
class="s">"1"</span><span class="o">)</span>
+<span class="n">changelogConfig</span><span class="o">.</span><span
class="na">put</span><span class="o">(</span><span
class="n">TopicConfig</span><span class="o">.</span><span
class="na">MIN_IN_SYNC_REPLICAS_CONFIG</span><span class="o">,</span> <span
class="s">"1"</span><span class="o">)</span>
<span class="n">StoreBuilder</span><span class="o"><</span><span
class="n">KeyValueStore</span><span class="o"><</span><span
class="n">String</span><span class="o">,</span> <span
class="n">Long</span><span class="o">>></span> <span
class="n">countStoreSupplier</span> <span class="o">=</span> <span
class="n">Stores</span><span class="o">.</span><span
class="na">keyValueStoreBuilder</span><span class="o">(</span>
<span class="n">Stores</span><span class="o">.</span><span
class="na">persistentKeyValueStore</span><span class="o">(</span><span
class="s">"Counts"</span><span class="o">),</span>
