Update AK versions to 3.4.0 (#1540)

bbejeck · web-flow · commit 57416ca442a3 · 2023-04-14T13:52:00.000-04:00
* Update AK versions to 3.4.0

* Updates to remove deprecated configs

* Add override for explicitly setting client dependency to match kafka streams and
not from a transitive dependency

* formatting

* formatting - include all file this time
diff --git a/_includes/tutorials/aggregating-average/kstreams/code/build.gradle b/_includes/tutorials/aggregating-average/kstreams/code/build.gradle
@@ -31,11 +31,16 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
   implementation "org.apache.avro:avro:1.11.1"
   implementation "org.slf4j:slf4j-simple:2.0.7"
-  implementation "org.apache.kafka:kafka-streams:3.3.1"
+  implementation 'org.apache.kafka:kafka-streams:3.4.0'
+  implementation ('org.apache.kafka:kafka-clients') {
+    version {
+        strictly '3.4.0'
+    }
+  }
   implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
   implementation "com.typesafe:config:1.4.2"
 
-  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
   testImplementation "junit:junit:4.13.2"
   testImplementation 'org.hamcrest:hamcrest:2.2'
 
diff --git a/_includes/tutorials/aggregating-average/kstreams/code/src/main/java/io/confluent/developer/RunningAverage.java b/_includes/tutorials/aggregating-average/kstreams/code/src/main/java/io/confluent/developer/RunningAverage.java
@@ -61,7 +61,7 @@ protected Properties buildStreamsProperties(Properties envProps) {
     config.put(REPLICATION_FACTOR_CONFIG, envProps.getProperty("default.topic.replication.factor"));
     config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, envProps.getProperty("offset.reset.policy"));
 
-    config.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    config.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
 
     return config;
   }
diff --git a/_includes/tutorials/aggregating-count/kstreams/code/build.gradle b/_includes/tutorials/aggregating-count/kstreams/code/build.gradle
@@ -31,9 +31,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
 }
 
diff --git a/_includes/tutorials/aggregating-count/kstreams/code/src/main/java/io/confluent/developer/AggregatingCount.java b/_includes/tutorials/aggregating-count/kstreams/code/src/main/java/io/confluent/developer/AggregatingCount.java
@@ -100,7 +100,7 @@ private void runRecipe(final String configPath) throws IOException {
     }
     allProps.put(StreamsConfig.APPLICATION_ID_CONFIG, allProps.getProperty("application.id"));
     allProps.put(StreamsConfig.STATE_DIR_CONFIG, TestUtils.tempDirectory().getPath());
-    allProps.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    allProps.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
 
     Topology topology = this.buildTopology(allProps, this.ticketSaleSerde(allProps));
     this.createTopics(allProps);
diff --git a/_includes/tutorials/aggregating-minmax/kstreams/code/build.gradle b/_includes/tutorials/aggregating-minmax/kstreams/code/build.gradle
@@ -33,9 +33,14 @@ mainClassName = "io.confluent.developer.AggregatingMinMax"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/aggregating-minmax/kstreams/code/src/main/java/io/confluent/developer/AggregatingMinMax.java b/_includes/tutorials/aggregating-minmax/kstreams/code/src/main/java/io/confluent/developer/AggregatingMinMax.java
@@ -42,7 +42,7 @@ public static Properties buildStreamsProperties(Properties envProps) {
     props.put(StreamsConfig.APPLICATION_ID_CONFIG, envProps.getProperty("application.id"));
     props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, envProps.getProperty("bootstrap.servers"));
     props.put(SCHEMA_REGISTRY_URL_CONFIG, envProps.getProperty("schema.registry.url"));
-    props.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    props.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
 
     return props;
   }
diff --git a/_includes/tutorials/aggregating-sum/kstreams/code/build.gradle b/_includes/tutorials/aggregating-sum/kstreams/code/build.gradle
@@ -30,9 +30,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
 }
 
diff --git a/_includes/tutorials/aggregating-sum/kstreams/code/src/main/java/io/confluent/developer/AggregatingSum.java b/_includes/tutorials/aggregating-sum/kstreams/code/src/main/java/io/confluent/developer/AggregatingSum.java
@@ -100,7 +100,7 @@ private void runRecipe(final String configPath) throws IOException {
     }
     allProps.put(StreamsConfig.APPLICATION_ID_CONFIG, allProps.getProperty("application.id"));
     allProps.put(StreamsConfig.STATE_DIR_CONFIG, TestUtils.tempDirectory().getPath());
-    allProps.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    allProps.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
 
     Topology topology = this.buildTopology(allProps, this.ticketSaleSerde(allProps));
     this.createTopics(allProps);
diff --git a/_includes/tutorials/cogrouping-streams/kstreams/code/build.gradle b/_includes/tutorials/cogrouping-streams/kstreams/code/build.gradle
@@ -32,10 +32,15 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
 
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/connect-add-key-to-source/kstreams/code/build.gradle b/_includes/tutorials/connect-add-key-to-source/kstreams/code/build.gradle
@@ -31,11 +31,16 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
   implementation "org.apache.avro:avro:1.11.1"
   implementation "org.slf4j:slf4j-simple:2.0.7"
-  implementation "org.apache.kafka:kafka-streams:3.3.1"
+  implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
   implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
   implementation 'com.google.code.gson:gson:2.10.1'
 
-  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
   testImplementation 'junit:junit:4.13.2'
 }
 
diff --git a/_includes/tutorials/connect-add-key-to-source/kstreams/code/src/main/java/io/confluent/developer/connect/jdbc/specificavro/StreamsIngest.java b/_includes/tutorials/connect-add-key-to-source/kstreams/code/src/main/java/io/confluent/developer/connect/jdbc/specificavro/StreamsIngest.java
@@ -39,7 +39,7 @@ public Properties buildStreamsProperties(Properties envProps) {
     props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass());
     props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass());
     props.put(SCHEMA_REGISTRY_URL_CONFIG, envProps.getProperty("schema.registry.url"));
-    props.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    props.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
 
     return props;
   }
diff --git a/_includes/tutorials/creating-first-apache-kafka-streams-application/kstreams/code/build.gradle b/_includes/tutorials/creating-first-apache-kafka-streams-application/kstreams/code/build.gradle
@@ -35,9 +35,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 
 dependencies {
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation 'com.github.javafaker:javafaker:1.0.2'
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/dynamic-output-topic/kstreams/code/build.gradle b/_includes/tutorials/dynamic-output-topic/kstreams/code/build.gradle
@@ -32,9 +32,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/error-handling/kstreams/code/build.gradle b/_includes/tutorials/error-handling/kstreams/code/build.gradle
@@ -32,10 +32,15 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "org.apache.kafka:kafka-clients:3.1.0"
     
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/filtering/kstreams/code/build.gradle b/_includes/tutorials/filtering/kstreams/code/build.gradle
@@ -30,9 +30,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
   implementation "org.apache.avro:avro:1.11.1"
   implementation "org.slf4j:slf4j-simple:2.0.7"
-  implementation "org.apache.kafka:kafka-streams:3.3.1"
+  implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
   implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
   testImplementation "junit:junit:4.13.2"
 }
 
diff --git a/_includes/tutorials/fk-joins/kstreams/code/build.gradle b/_includes/tutorials/fk-joins/kstreams/code/build.gradle
@@ -30,9 +30,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
   implementation "org.apache.avro:avro:1.11.1"
   implementation "org.slf4j:slf4j-simple:2.0.7"
-  implementation "org.apache.kafka:kafka-streams:3.3.1"
+  implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
   implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+  testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
   testImplementation "junit:junit:4.13.2"
 }
 
diff --git a/_includes/tutorials/joining-stream-table/kstreams/code/build.gradle b/_includes/tutorials/joining-stream-table/kstreams/code/build.gradle
@@ -30,9 +30,14 @@ apply plugin: 'com.github.johnrengelman.shadow'
 dependencies {
   implementation 'org.apache.avro:avro:1.11.1'
   implementation 'org.slf4j:slf4j-simple:2.0.7'
-  implementation 'org.apache.kafka:kafka-streams:3.3.1'
+  implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
   implementation 'io.confluent:kafka-streams-avro-serde:7.3.0'
-  testImplementation 'org.apache.kafka:kafka-streams-test-utils:3.3.1'
+  testImplementation 'org.apache.kafka:kafka-streams-test-utils:3.4.0'
   testImplementation 'junit:junit:4.13.2'
 }
 
diff --git a/_includes/tutorials/kafka-consumer-application/kafka/code/build.gradle b/_includes/tutorials/kafka-consumer-application/kafka/code/build.gradle
@@ -30,7 +30,7 @@ apply plugin: "com.github.johnrengelman.shadow"
 
 dependencies {
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-clients:3.3.1"
+    implementation "org.apache.kafka:kafka-clients:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/kafka-producer-application-callback/kafka/code/build.gradle b/_includes/tutorials/kafka-producer-application-callback/kafka/code/build.gradle
@@ -30,8 +30,13 @@ apply plugin: "com.github.johnrengelman.shadow"
 
 dependencies {
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/kafka-producer-application/kafka/code/build.gradle b/_includes/tutorials/kafka-producer-application/kafka/code/build.gradle
@@ -30,8 +30,8 @@ apply plugin: "com.github.johnrengelman.shadow"
 
 dependencies {
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-clients:3.3.1"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    implementation "org.apache.kafka:kafka-clients:3.4.0"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/merging/kstreams/code/build.gradle b/_includes/tutorials/merging/kstreams/code/build.gradle
@@ -30,9 +30,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
 }
 
diff --git a/_includes/tutorials/message-ordering/kafka/code/build.gradle b/_includes/tutorials/message-ordering/kafka/code/build.gradle
@@ -29,7 +29,12 @@ apply plugin: "com.github.johnrengelman.shadow"
 
 dependencies {
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/multiple-event-types/kafka/code/build.gradle b/_includes/tutorials/multiple-event-types/kafka/code/build.gradle
@@ -48,7 +48,12 @@ dependencies {
     implementation 'com.google.protobuf:protobuf-java:3.22.2'
     implementation 'org.apache.avro:avro:1.11.1'
     implementation 'org.slf4j:slf4j-simple:2.0.7'
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
     implementation "io.confluent:kafka-avro-serializer:7.1.4"
diff --git a/_includes/tutorials/naming-changelog-repartition-topics/kstreams/code/build.gradle b/_includes/tutorials/naming-changelog-repartition-topics/kstreams/code/build.gradle
@@ -33,9 +33,14 @@ apply plugin: "com.github.johnrengelman.shadow"
 dependencies {
     implementation "org.apache.avro:avro:1.11.1"
     implementation "org.slf4j:slf4j-simple:2.0.7"
-    implementation "org.apache.kafka:kafka-streams:3.3.1"
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation ('org.apache.kafka:kafka-clients') {
+       version {
+           strictly '3.4.0'
+        }
+      }
     implementation "io.confluent:kafka-streams-avro-serde:7.3.0"
-    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.3.1"
+    testImplementation "org.apache.kafka:kafka-streams-test-utils:3.4.0"
     testImplementation "junit:junit:4.13.2"
     testImplementation 'org.hamcrest:hamcrest:2.2'
 }
diff --git a/_includes/tutorials/naming-changelog-repartition-topics/kstreams/code/src/main/java/io/confluent/developer/NamingChangelogAndRepartitionTopics.java b/_includes/tutorials/naming-changelog-repartition-topics/kstreams/code/src/main/java/io/confluent/developer/NamingChangelogAndRepartitionTopics.java
@@ -38,7 +38,7 @@ public Properties buildStreamsProperties(Properties envProps) {
     props.put(StreamsConfig.APPLICATION_ID_CONFIG, envProps.getProperty("application.id"));
     props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, envProps.getProperty("bootstrap.servers"));
     props.put(StreamsConfig.STATE_DIR_CONFIG, TestUtils.tempDirectory().getPath());
-    props.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    props.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
 
     return props;
   }
diff --git a/_includes/tutorials/schedule-ktable-ttl-aggregate/kstreams/code/src/main/java/io/confluent/developer/KafkaStreamsKTableTTLExample.java b/_includes/tutorials/schedule-ktable-ttl-aggregate/kstreams/code/src/main/java/io/confluent/developer/KafkaStreamsKTableTTLExample.java
@@ -140,7 +140,7 @@ public Properties loadEnvProperties(String fileName) throws IOException {
 
     // These two settings are only required in this contrived example so that the
     // streamsConfiguration.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 0);
-    // streamsConfiguration.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    // streamsConfiguration.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
     return envProps;
   }
 
diff --git a/_includes/tutorials/schedule-ktable-ttl/kstreams/code/src/main/java/io/confluent/developer/KafkaStreamsKTableTTLExample.java b/_includes/tutorials/schedule-ktable-ttl/kstreams/code/src/main/java/io/confluent/developer/KafkaStreamsKTableTTLExample.java
@@ -120,7 +120,7 @@ public Properties getStreamProps(Properties envProp) {
     
     // These two settings are only required in this contrived example so that the 
     // streamsConfiguration.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 0);
-    // streamsConfiguration.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    // streamsConfiguration.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
     return streamsConfiguration;
   }
 
@@ -159,7 +159,7 @@ public Properties loadEnvProperties(String fileName) throws IOException {
     
     // These two settings are only required in this contrived example so that the 
     // streamsConfiguration.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, 0);
-    // streamsConfiguration.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);
+    // streamsConfiguration.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);
     return envProps;
   }
 
diff --git a/_includes/tutorials/serialization/kstreams/code/build.gradle b/_includes/tutorials/serialization/kstreams/code/build.gradle
diff --git a/_includes/tutorials/serialization/kstreams/code/src/test/java/io/confluent/developer/serialization/SerializationTutorialTest.java b/_includes/tutorials/serialization/kstreams/code/src/test/java/io/confluent/developer/serialization/SerializationTutorialTest.java
diff --git a/_includes/tutorials/session-windows/kstreams/code/build.gradle b/_includes/tutorials/session-windows/kstreams/code/build.gradle
diff --git a/_includes/tutorials/sliding-windows/kstreams/code/build.gradle b/_includes/tutorials/sliding-windows/kstreams/code/build.gradle
diff --git a/_includes/tutorials/splitting/kstreams/code/build.gradle b/_includes/tutorials/splitting/kstreams/code/build.gradle
diff --git a/_includes/tutorials/streams-to-table/kstreams/code/build.gradle b/_includes/tutorials/streams-to-table/kstreams/code/build.gradle
diff --git a/_includes/tutorials/time-concepts/ksql/code/build.gradle b/_includes/tutorials/time-concepts/ksql/code/build.gradle
diff --git a/_includes/tutorials/transforming/kstreams/code/build.gradle b/_includes/tutorials/transforming/kstreams/code/build.gradle
diff --git a/_includes/tutorials/tumbling-windows/kstreams/code/build.gradle b/_includes/tutorials/tumbling-windows/kstreams/code/build.gradle
diff --git a/_includes/tutorials/tumbling-windows/kstreams/code/src/main/java/io/confluent/developer/TumblingWindow.java b/_includes/tutorials/tumbling-windows/kstreams/code/src/main/java/io/confluent/developer/TumblingWindow.java
diff --git a/_includes/tutorials/window-final-result/kstreams/code/build.gradle b/_includes/tutorials/window-final-result/kstreams/code/build.gradle
diff --git a/_includes/tutorials/window-final-result/kstreams/code/src/main/java/io/confluent/developer/WindowFinalResult.java b/_includes/tutorials/window-final-result/kstreams/code/src/main/java/io/confluent/developer/WindowFinalResult.java

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ protected Properties buildStreamsProperties(Properties envProps) {`
`61`	`61`	`config.put(REPLICATION_FACTOR_CONFIG, envProps.getProperty("default.topic.replication.factor"));`
`62`	`62`	`config.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, envProps.getProperty("offset.reset.policy"));`
`63`	`63`
`64`		`- config.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);`
	`64`	`+ config.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);`
`65`	`65`
`66`	`66`	`return config;`
`67`	`67`	`}`
Original file line number	Diff line number	Diff line change
`@@ -100,7 +100,7 @@ private void runRecipe(final String configPath) throws IOException {`
`100`	`100`	`}`
`101`	`101`	`allProps.put(StreamsConfig.APPLICATION_ID_CONFIG, allProps.getProperty("application.id"));`
`102`	`102`	`allProps.put(StreamsConfig.STATE_DIR_CONFIG, TestUtils.tempDirectory().getPath());`
`103`		`- allProps.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);`
	`103`	`+ allProps.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);`
`104`	`104`
`105`	`105`	`Topology topology = this.buildTopology(allProps, this.ticketSaleSerde(allProps));`
`106`	`106`	`this.createTopics(allProps);`
Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ public static Properties buildStreamsProperties(Properties envProps) {`
`42`	`42`	`props.put(StreamsConfig.APPLICATION_ID_CONFIG, envProps.getProperty("application.id"));`
`43`	`43`	`props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, envProps.getProperty("bootstrap.servers"));`
`44`	`44`	`props.put(SCHEMA_REGISTRY_URL_CONFIG, envProps.getProperty("schema.registry.url"));`
`45`		`- props.put(StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG, 0);`
	`45`	`+ props.put(StreamsConfig.STATESTORE_CACHE_MAX_BYTES_CONFIG, 0);`
`46`	`46`
`47`	`47`	`return props;`
`48`	`48`	`}`