kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] branch trunk updated: MINOR: Update documentation for enabling optimizations (#7099)
Date Fri, 19 Jul 2019 17:15:31 GMT
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 d054875  MINOR: Update documentation for enabling optimizations (#7099)
d054875 is described below

commit d0548758e5c89f0d387332227ae8f844f15a8772
Author: Bill Bejeck <bbejeck@gmail.com>
AuthorDate: Fri Jul 19 13:15:17 2019 -0400

    MINOR: Update documentation for enabling optimizations (#7099)
    Updated docs for enabling all optimizations as of 2.3
    Reviewers: Victoria Bialas <vicky@confluent.io>, Matthias J. Sax <mjsax@apache.org>
 docs/streams/upgrade-guide.html | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html
index 2065445..0d10442 100644
--- a/docs/streams/upgrade-guide.html
+++ b/docs/streams/upgrade-guide.html
@@ -81,6 +81,14 @@
+        As of 2.3.0 we've updated how to turn on optimizations. Now to enable optimizations,
you need to do two things.
+        First add this line to your properties <code>properties.setProperty(StreamsConfig.TOPOLOGY_OPTIMIZATION,
StreamsConfig.OPTIMIZE);</code>, as you have done before.
+        Second, when constructing your <code>KafkaStreams</code> instance, you'll
need to pass your configuration properties when building your
+        topology by using the overloaded <code>StreamsBuilder.build(Properties)</code>
+        For example <code>KafkaStreams myStream = new KafkaStreams(streamsBuilder.build(properties),
+    </p>
+    <p>
         In 2.3.0 we have added default implementation to <code>close()</code>
and <code>configure()</code> for <code>Serializer</code>,
         <code>Deserializer</code> and <code>Serde</code> so that
they can be implemented by lambda expression.
         For more details please read <a href="https://cwiki.apache.org/confluence/display/KAFKA/KIP-331+Add+default+implementation+to+close%28%29+and+configure%28%29+for+Serializer%2C+Deserializer+and+Serde">KIP-331</a>.

View raw message