From 586a447105d9fb481e3c6504f0750149c0d4e59a Mon Sep 17 00:00:00 2001 From: Bill Bejeck Date: Wed, 17 Jul 2019 12:05:07 -0400 Subject: [PATCH 1/3] MINOR: Update documentation for enabling optimizations --- 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 2065445382a06..8a84b6728aa2e 100644 --- a/docs/streams/upgrade-guide.html +++ b/docs/streams/upgrade-guide.html @@ -80,6 +80,14 @@

Streams API The new public interfaces inMemoryWindowStore() and inMemorySessionStore() are added to Stores and provide the built-in in-memory window or session store.

+

+ 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 properties.setProperty(StreamsConfig.TOPOLOGY_OPTIMIZATION, StreamsConfig.OPTIMIZE);, as you have done before. + Second, when constructing your KafkaStreams instance, you'll need to pass your configuration properties when building your + topology via the overloaded StreamsBuilder.build(Properties) method. + For example KafkaStreams myStream = new KafkaStreams(streamsBuilder.build(properties), properties). +

+

In 2.3.0 we have added default implementation to close() and configure() for Serializer, Deserializer and Serde so that they can be implemented by lambda expression. From 1d385c6930f51a78e1827808699b669e0180343d Mon Sep 17 00:00:00 2001 From: Bill Bejeck Date: Fri, 19 Jul 2019 13:08:50 -0400 Subject: [PATCH 2/3] Update docs/streams/upgrade-guide.html Co-Authored-By: Victoria Bialas --- docs/streams/upgrade-guide.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html index 8a84b6728aa2e..2b520bf6f39f5 100644 --- a/docs/streams/upgrade-guide.html +++ b/docs/streams/upgrade-guide.html @@ -82,7 +82,7 @@

Streams API

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 properties.setProperty(StreamsConfig.TOPOLOGY_OPTIMIZATION, StreamsConfig.OPTIMIZE);, as you have done before. + First add this line to your properties properties.setProperty(StreamsConfig.TOPOLOGY_OPTIMIZATION, StreamsConfig.OPTIMIZE);, as you have done before. Second, when constructing your KafkaStreams instance, you'll need to pass your configuration properties when building your topology via the overloaded StreamsBuilder.build(Properties) method. For example KafkaStreams myStream = new KafkaStreams(streamsBuilder.build(properties), properties). From 9f9d7e12ab9215343f1c7f905176c6421d0225e6 Mon Sep 17 00:00:00 2001 From: Bill Bejeck Date: Fri, 19 Jul 2019 13:09:01 -0400 Subject: [PATCH 3/3] Update docs/streams/upgrade-guide.html Co-Authored-By: Victoria Bialas --- docs/streams/upgrade-guide.html | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/streams/upgrade-guide.html b/docs/streams/upgrade-guide.html index 2b520bf6f39f5..0d10442230e08 100644 --- a/docs/streams/upgrade-guide.html +++ b/docs/streams/upgrade-guide.html @@ -84,7 +84,7 @@

Streams API 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 properties.setProperty(StreamsConfig.TOPOLOGY_OPTIMIZATION, StreamsConfig.OPTIMIZE);, as you have done before. Second, when constructing your KafkaStreams instance, you'll need to pass your configuration properties when building your - topology via the overloaded StreamsBuilder.build(Properties) method. + topology by using the overloaded StreamsBuilder.build(Properties) method. For example KafkaStreams myStream = new KafkaStreams(streamsBuilder.build(properties), properties).