Bump Confluent to 4.0.0, Kafka to 1.0.0

README.md

@@ -315,7 +315,7 @@ Kafka Streams examples via:
 #
 $ mvn clean package
 
-# >>> Creates target/streams-examples-3.3.0-standalone.jar
+# >>> Creates target/streams-examples-4.0.0-standalone.jar
 
 ```
 
@@ -324,7 +324,7 @@ You can now run the example applications as follows:
 ```shell
 # Run an example application from the standalone jar.
 # Here: `WordCountLambdaExample`
-$ java -cp target/streams-examples-3.3.0-standalone.jar \
+$ java -cp target/streams-examples-4.0.0-standalone.jar \
   io.confluent.examples.streams.WordCountLambdaExample
 ```
 
@@ -340,7 +340,7 @@ and then execute as follows:
 ```shell
 # Run an example application from the standalone jar.
 # Here: `WordCountLambdaExample`
-$ java -cp target/streams-examples-3.3.0-standalone.jar \
+$ java -cp target/streams-examples-4.0.0-standalone.jar \
   -Dlog4j.configuration=file:src/main/resources/log4j.properties \
   io.confluent.examples.streams.WordCountLambdaExample
 ```

docker-compose.yml

@@ -2,7 +2,7 @@
 version: '2'
 services:
   zookeeper:
-    image: confluentinc/cp-zookeeper:3.3.0
+    image: confluentinc/cp-zookeeper:4.0.0
     hostname: zookeeper
     ports:
       - '32181:32181'
@@ -13,7 +13,7 @@ services:
       - "moby:127.0.0.1"
 
   kafka:
-    image: confluentinc/cp-enterprise-kafka:3.3.0
+    image: confluentinc/cp-enterprise-kafka:4.0.0
     hostname: kafka
     ports:
       - '9092:9092'
@@ -38,7 +38,7 @@ services:
       - "moby:127.0.0.1"
 
   schema-registry:
-    image: confluentinc/cp-schema-registry:3.3.0
+    image: confluentinc/cp-schema-registry:4.0.0
     hostname: schema-registry
     depends_on:
       - zookeeper
@@ -54,7 +54,7 @@ services:
   # This "container" is a workaround to pre-create topics for the Kafka Music application
   # until we have a more elegant way to do that.
   kafka-create-topics:
-    image: confluentinc/cp-kafka:3.3.0
+    image: confluentinc/cp-kafka:4.0.0
     depends_on:
       - kafka
     hostname: kafka-create-topics
@@ -78,7 +78,7 @@ services:
 
   # Continuously generates input data for the Kafka Music application.
   kafka-music-data-generator:
-    image: confluentinc/cp-kafka-streams-examples:3.3.1-SNAPSHOT
+    image: confluentinc/cp-kafka-streams-examples:4.0.0
     hostname: kafka-music-data-generator
     depends_on:
       - kafka
@@ -89,7 +89,7 @@ services:
                        cub kafka-ready -b kafka:29092 1 20 && \
                        echo Waiting for Confluent Schema Registry to be ready... && \
                        cub sr-ready schema-registry 8081 20 && \
-                       java -cp /app/streams-examples-3.3.1-SNAPSHOT-standalone.jar \
+                       java -cp /app/streams-examples-4.0.0-standalone.jar \
                        io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExampleDriver \
                        kafka:29092 http://schema-registry:8081'"
     environment:
@@ -103,7 +103,7 @@ services:
 
   # Runs the Kafka Music application.
   kafka-music-application:
-    image: confluentinc/cp-kafka-streams-examples:3.3.1-SNAPSHOT
+    image: confluentinc/cp-kafka-streams-examples:4.0.0
     hostname: kafka-music-application
     depends_on:
       - kafka

docs/kafka-streams-examples.rst

@@ -145,14 +145,14 @@ Running further Confluent demo applications for the Kafka Streams API
 
 The container named ``kafka-music-application``, which runs the Kafka Music demo application, actually contains all of
 Confluent's `Kafka Streams demo applications <https://github.com/confluentinc/examples>`__.  The demo applications are
-packaged in the fat jar at ``/app/streams-examples-3.3.0-standalone.jar`` inside this container.
+packaged in the fat jar at ``/app/streams-examples-4.0.0-standalone.jar`` inside this container.
 This means you can easily run any of these applications from inside the container via a command similar to:
 
 .. sourcecode:: bash
 
     # Example: Launch the WordCount demo application (inside the `kafka-music-application` container)
     $ docker-compose exec kafka-music-application \
-            java -cp /app/streams-examples-3.3.0-standalone.jar \
+            java -cp /app/streams-examples-4.0.0-standalone.jar \
             io.confluent.examples.streams.WordCountLambdaExample \
             kafka:29092
 

pom.xml

@@ -51,7 +51,7 @@
         <jackson.version>2.8.8</jackson.version>
         <jersey.version>2.25</jersey.version>
         <jetty.version>9.2.12.v20150709</jetty.version>
-        <licenses.version>3.3.1-SNAPSHOT</licenses.version>
+        <licenses.version>4.0.0</licenses.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <scala.version>${kafka.scala.version}.8</scala.version>
         <scalatest.version>2.2.6</scalatest.version>

src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java

@@ -54,7 +54,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.AnomalyDetectionLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.AnomalyDetectionLambdaExample
  * }</pre>
  * <p>
  * 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}. The already

src/main/java/io/confluent/examples/streams/ApplicationResetExample.java

@@ -43,7 +43,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.ApplicationResetExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.ApplicationResetExample
  * }</pre>
  * 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}).
  * The already running example application (step 3) will automatically process this input data and write the results to the output topics.
@@ -97,7 +97,7 @@
  * Thus, restart the application via:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.ApplicationResetExample --reset
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.ApplicationResetExample --reset
  * }</pre>
  * 9) If your console consumer (from step 5) is still running, you should see the same output data again.
  * If it was stopped and you restart it, if will print the result "twice".

src/main/java/io/confluent/examples/streams/GlobalKTablesExample.java

@@ -66,7 +66,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.GlobalKTablesExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.GlobalKTablesExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@link GlobalKTablesExampleDriver}). The
  * already running example application (step 3) will automatically process this input data and write
@@ -75,7 +75,7 @@
  * {@code
  * # Here: Write input data using the example driver. The driver will exit once it has received
  * # all EnrichedOrders
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
  * }</pre>
  * <p>
  * 5) Once you're done with your experiments, you can stop this example via {@code Ctrl-C}. If needed,

src/main/java/io/confluent/examples/streams/GlobalKTablesExampleDriver.java

@@ -54,7 +54,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
  * }</pre>
  */
 public class GlobalKTablesExampleDriver {

src/main/java/io/confluent/examples/streams/MapFunctionLambdaExample.java

@@ -56,7 +56,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.MapFunctionLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.MapFunctionLambdaExample
  * }</pre>
  * 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}). The already
  * running example application (step 3) will automatically process this input data and write the

src/main/java/io/confluent/examples/streams/PageViewRegionExample.java

@@ -77,7 +77,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@link PageViewRegionExampleDriver}). The
  * already running example application (step 3) will automatically process this input data and write
@@ -86,7 +86,7 @@
  * {@code
  * # Here: Write input data using the example driver. Once the driver has stopped generating data,
  * # you can terminate it via `Ctrl-C`.
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
  * }</pre>
  * 5) Inspect the resulting data in the output topic, e.g. via {@code kafka-console-consumer}.
  * <pre>

src/main/java/io/confluent/examples/streams/PageViewRegionExampleDriver.java

@@ -47,7 +47,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
  * }</pre>
  * You should terminate with {@code Ctrl-C}.
  */

src/main/java/io/confluent/examples/streams/PageViewRegionLambdaExample.java

@@ -73,7 +73,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@link PageViewRegionExampleDriver}).
  * The already running example application (step 3) will automatically process this input data and
@@ -82,7 +82,7 @@
  * {@code
  * # Here: Write input data using the example driver. Once the driver has stopped generating data,
  * # you can terminate it via `Ctrl-C`.
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
  * }</pre>
  * 5) Inspect the resulting data in the output topic, e.g. via {@code kafka-console-consumer}.
  * <pre>

src/main/java/io/confluent/examples/streams/SecureKafkaStreamsExample.java

@@ -98,7 +98,7 @@
  * [vagrant@kafka ~]$ mvn clean -DskipTests=true package
  *
  * # Now we can start this example application
- * [vagrant@kafka ~]$ java -cp target/streams-examples-3.3.0-standalone.jar \
+ * [vagrant@kafka ~]$ java -cp target/streams-examples-4.0.0-standalone.jar \
  *                             io.confluent.examples.streams.SecureKafkaStreamsExample
  * }</pre>
  * 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}). The already

src/main/java/io/confluent/examples/streams/SessionWindowsExample.java

@@ -63,7 +63,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.SessionWindowsExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.SessionWindowsExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@link SessionWindowsExampleDriver}). The
  * already running example application (step 3) will automatically process this input data and write
@@ -72,7 +72,7 @@
  * {@code
  * # Here: Write input data using the example driver. The driver will also consume, and print, the data from the output
  * topic. The driver will stop when it has received all output records
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
  * }</pre>
  * You should see output data similar to:
  * <pre>

src/main/java/io/confluent/examples/streams/SessionWindowsExampleDriver.java

@@ -43,7 +43,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
  * }</pre>
  */
 public class SessionWindowsExampleDriver {

src/main/java/io/confluent/examples/streams/SumLambdaExample.java

@@ -50,7 +50,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.SumLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.SumLambdaExample
  * }</pre>
  * 4) Write some input data to the source topic (e.g. via {@link SumLambdaExampleDriver}). The
  * already running example application (step 3) will automatically process this input data and write
@@ -59,7 +59,7 @@
  * {@code
  * # Here: Write input data using the example driver. Once the driver has stopped generating data,
  * # you can terminate it via `Ctrl-C`.
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
  * }</pre>
  * 5) Inspect the resulting data in the output topics, e.g. via {@code kafka-console-consumer}.
  * <pre>

src/main/java/io/confluent/examples/streams/SumLambdaExampleDriver.java

@@ -38,7 +38,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
  * }</pre>
  * You should terminate with {@code Ctrl-C}.
  * Please refer to {@link SumLambdaExample} for instructions on running the example.

src/main/java/io/confluent/examples/streams/TopArticlesExampleDriver.java

@@ -48,7 +48,7 @@
  * <a href='https://github.com/confluentinc/examples/tree/master/kafka-streams#packaging-and-running'>Packaging</a>
  *
  * Once packaged you can then run:
- * java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
+ * java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
  *
  * You should terminate with Ctrl-C
  */

src/main/java/io/confluent/examples/streams/TopArticlesLambdaExample.java

@@ -78,7 +78,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@link TopArticlesExampleDriver}).
  * The already running example application (step 3) will automatically process this input data and
@@ -88,7 +88,7 @@
  * {@code
  * # Here: Write input data using the example driver.  Once the driver has stopped generating data,
  * # you can terminate it via Ctrl-C.
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.TopArticlesExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.TopArticlesExampleDriver
  * }</pre>
  */
 public class TopArticlesLambdaExample {

src/main/java/io/confluent/examples/streams/UserRegionLambdaExample.java

@@ -51,7 +51,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.UserRegionLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.UserRegionLambdaExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@code kafka-console-producer}). The already
  * running example application (step 3) will automatically process this input data and write the

src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExample.java

@@ -58,7 +58,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@link WikipediaFeedAvroExampleDriver}).
  * The already running example application (step 3) will automatically process this input data and
@@ -68,7 +68,7 @@
  * {@code
  * # Here: Write input data using the example driver.  Once the driver has stopped generating data,
  * # you can terminate it via Ctrl-C.
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
  * }</pre>
  */
 

src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExampleDriver.java

@@ -42,7 +42,7 @@
  * <a href='https://github.com/confluentinc/examples/tree/master/kafka-streams#packaging-and-running'>Packaging</a>
  *
  * Once packaged you can then run:
- * java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
+ * java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
  *
  * You should terminate with Ctrl-C
  */

src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java

@@ -55,7 +55,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroLambdaExample
  * }</pre>
  * 4) Write some input data to the source topics (e.g. via {@link WikipediaFeedAvroExampleDriver}).
  * The already running example application (step 3) will automatically process this input data and
@@ -65,7 +65,7 @@
  * {@code
  * # Here: Write input data using the example driver.  Once the driver has stopped generating data,
  * # you can terminate it via Ctrl-C.
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
  * }</pre>
  */
 public class WikipediaFeedAvroLambdaExample {

src/main/java/io/confluent/examples/streams/WordCountLambdaExample.java

@@ -59,7 +59,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.WordCountLambdaExample
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.WordCountLambdaExample
  * }</pre>
  * 4) Write some input data to the source topic "TextLinesTopic" (e.g. via {@code kafka-console-producer}).
  * The already running example application (step 3) will automatically process this input data and write the

src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesDriver.java

@@ -35,7 +35,7 @@
  * Once packaged you can then run:
  * <pre>
  * {@code
- * $ java -cp target/streams-examples-3.3.0-standalone.jar io.confluent.examples.streams.interactivequeries.InteractiveQueriesExampleDriver
+ * $ java -cp target/streams-examples-4.0.0-standalone.jar io.confluent.examples.streams.interactivequeries.InteractiveQueriesExampleDriver
  * }
  * </pre>
  * You should terminate with Ctrl-C