This is an automated email from the ASF dual-hosted git repository. bbejeck pushed a commit to branch 2.3 in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.3 by this push: new 6916e86 MINOR: Update documentation for enabling optimizations (#7099) 6916e86 is described below commit 6916e8618c609a018df405b79e62fa550289e475 Author: Bill Bejeck <bbej...@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 <vi...@confluent.io>, Matthias J. Sax <mj...@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 4b3dac2..fe24ecb 100644 --- a/docs/streams/upgrade-guide.html +++ b/docs/streams/upgrade-guide.html @@ -81,6 +81,14 @@ </p> <p> + 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> method. + For example <code>KafkaStreams myStream = new KafkaStreams(streamsBuilder.build(properties), properties)</code>. + </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>.