This is an automated email from the ASF dual-hosted git repository.
mjsax 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 6e741ffeea1 MINOR: Extend streams quickstart with new protocol (#21093)
6e741ffeea1 is described below
commit 6e741ffeea19a8d07df624859387db591ccb1961
Author: Evan Zhou <[email protected]>
AuthorDate: Tue Dec 9 19:05:52 2025 -0800
MINOR: Extend streams quickstart with new protocol (#21093)
This PR adds a section in the Kafka Streams quickstart for enabling the
new `streams` protocol.
Reviewers: Lucas Brutschy <[email protected]>, Matthias J. Sax
<[email protected]>
---
docs/streams/quickstart.html | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/docs/streams/quickstart.html b/docs/streams/quickstart.html
index d3ceacae31f..c51202d9143 100644
--- a/docs/streams/quickstart.html
+++ b/docs/streams/quickstart.html
@@ -166,6 +166,12 @@ and continuously write its current results to the output
topic <b>streams-wordco
Hence there won't be any STDOUT output except log entries as the results are
written back into in Kafka.
</p>
+Optionally, use <code>group.protocol=streams</code> to enable the new
rebalancing protocol introduced in KIP-1071.
+This shifts task assignment logic from the client to the broker, reducing
rebalance times and eliminating stop-the-world rebalances.
+
+<pre><code class="language-bash">$ echo "group.protocol=streams" >
streams.properties
+$ bin/kafka-run-class.sh
org.apache.kafka.streams.examples.wordcount.WordCountDemo
streams.properties</code></pre>
+
Now we can start the console producer in a separate terminal to write some
input data to this topic:
<pre><code class="language-bash">$ bin/kafka-console-producer.sh
--bootstrap-server localhost:9092 --topic streams-plaintext-input</code></pre>