diff --git a/README.md b/README.md index 13f6d4953d..0a713d9936 100644 --- a/README.md +++ b/README.md @@ -319,7 +319,7 @@ The next step is to create a standalone jar ("fat jar") of the [application exam # Create a standalone jar ("fat jar") $ mvn clean package -# >>> Creates target/kafka-streams-examples-7.9.3-0-standalone.jar +# >>> Creates target/kafka-streams-examples-7.9.3-standalone.jar ``` > Tip: If needed, you can disable the test suite during packaging, for example to speed up the packaging or to lower @@ -333,7 +333,7 @@ You can now run the application examples as follows: ```shell # Run an example application from the standalone jar. Here: `WordCountLambdaExample` -$ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \ +$ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \ io.confluent.examples.streams.WordCountLambdaExample ``` @@ -348,7 +348,7 @@ If you want to turn on log4j while running your example application, you can edi ```shell # Run an example application from the standalone jar. Here: `WordCountLambdaExample` -$ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \ +$ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \ -Dlog4j.configuration=file:src/main/resources/log4j.properties \ io.confluent.examples.streams.WordCountLambdaExample ``` diff --git a/docker-compose.yml b/docker-compose.yml index 3e9b810359..86fdcf17f5 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -2,7 +2,7 @@ version: '2' services: zookeeper: - image: confluentinc/cp-zookeeper:7.9.x-latest + image: confluentinc/cp-zookeeper:7.9.3 hostname: zookeeper ports: - '32181:32181' @@ -13,7 +13,7 @@ services: - "moby:127.0.0.1" kafka: - image: confluentinc/cp-enterprise-kafka:7.9.x-latest + image: confluentinc/cp-enterprise-kafka:7.9.3 hostname: kafka ports: - '9092:9092' @@ -38,7 +38,7 @@ services: - "moby:127.0.0.1" schema-registry: - image: confluentinc/cp-schema-registry:7.9.x-latest + image: confluentinc/cp-schema-registry:7.9.3 hostname: schema-registry depends_on: - zookeeper @@ -56,7 +56,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:7.9.x-latest + image: confluentinc/cp-kafka:7.9.3 depends_on: - kafka hostname: kafka-create-topics @@ -81,7 +81,7 @@ services: # Continuously generates input data for the Kafka Music application. kafka-music-data-generator: - image: confluentinc/kafka-streams-examples:7.9.x-latest + image: confluentinc/kafka-streams-examples:7.9.3 hostname: kafka-music-data-generator depends_on: - kafka @@ -92,7 +92,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 /usr/share/java/kafka-streams-examples/kafka-streams-examples-7.9.3-0-standalone.jar \ + java -cp /usr/share/java/kafka-streams-examples/kafka-streams-examples-7.9.3-standalone.jar \ io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExampleDriver \ kafka:29092 http://schema-registry:8081'" environment: @@ -106,7 +106,7 @@ services: # Runs the Kafka Music application. kafka-music-application: - image: confluentinc/kafka-streams-examples:7.9.x-latest + image: confluentinc/kafka-streams-examples:7.9.3 hostname: kafka-music-application depends_on: - kafka diff --git a/pom.xml b/pom.xml index af5e24a441..0dd5e52684 100644 --- a/pom.xml +++ b/pom.xml @@ -7,12 +7,12 @@ io.confluent rest-utils-parent - [7.9.3-0, 7.9.4-0) + 7.9.3 kafka-streams-examples jar - 7.9.3-0 + 7.9.3 Confluent, Inc. @@ -64,7 +64,7 @@ ${project.version}-${docker.os_type} ${confluent.version.range} ${confluent.version.range} - 7.9.3-0 + 7.9.3 diff --git a/src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java b/src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java index 9b9ba0b81e..29815bc8ed 100644 --- a/src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java @@ -58,7 +58,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.AnomalyDetectionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.AnomalyDetectionLambdaExample
  * }
*

* 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}. The already diff --git a/src/main/java/io/confluent/examples/streams/ApplicationResetExample.java b/src/main/java/io/confluent/examples/streams/ApplicationResetExample.java index 67fbb90382..909d5c30cc 100644 --- a/src/main/java/io/confluent/examples/streams/ApplicationResetExample.java +++ b/src/main/java/io/confluent/examples/streams/ApplicationResetExample.java @@ -59,7 +59,7 @@ * Once packaged you can then run: *

  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.ApplicationResetExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.ApplicationResetExample
  * }
  * 
* 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}). @@ -114,7 +114,7 @@ * Thus, restart the application via: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.ApplicationResetExample localhost:9092 --reset
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.ApplicationResetExample localhost:9092 --reset
  * }
* 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". diff --git a/src/main/java/io/confluent/examples/streams/GlobalKTablesExample.java b/src/main/java/io/confluent/examples/streams/GlobalKTablesExample.java index a131e09208..19844aaa38 100644 --- a/src/main/java/io/confluent/examples/streams/GlobalKTablesExample.java +++ b/src/main/java/io/confluent/examples/streams/GlobalKTablesExample.java @@ -76,7 +76,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.GlobalKTablesExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.GlobalKTablesExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link GlobalKTablesAndStoresExampleDriver}). The @@ -86,7 +86,7 @@ * {@code * # Here: Write input data using the example driver. The driver will exit once it has received * # all EnrichedOrders - * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.GlobalKTablesAndStoresExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.GlobalKTablesAndStoresExampleDriver * } * *

diff --git a/src/main/java/io/confluent/examples/streams/JsonToAvroExample.java b/src/main/java/io/confluent/examples/streams/JsonToAvroExample.java index 2dee9fa926..8fbb6b2863 100644 --- a/src/main/java/io/confluent/examples/streams/JsonToAvroExample.java +++ b/src/main/java/io/confluent/examples/streams/JsonToAvroExample.java @@ -57,7 +57,7 @@ * Once packaged you can then run: *

  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.JsonToAvroExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.JsonToAvroExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link JsonToAvroExampleDriver}). The @@ -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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.JsonToAvroExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.JsonToAvroExampleDriver * } * */ diff --git a/src/main/java/io/confluent/examples/streams/JsonToAvroExampleDriver.java b/src/main/java/io/confluent/examples/streams/JsonToAvroExampleDriver.java index 70987b1903..84c6093e7d 100644 --- a/src/main/java/io/confluent/examples/streams/JsonToAvroExampleDriver.java +++ b/src/main/java/io/confluent/examples/streams/JsonToAvroExampleDriver.java @@ -49,7 +49,7 @@ * Once packaged you can then run: *
  * {@code
- * java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.JsonToAvroExampleDriver
+ * java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.JsonToAvroExampleDriver
  * }
  * 
* diff --git a/src/main/java/io/confluent/examples/streams/MapFunctionLambdaExample.java b/src/main/java/io/confluent/examples/streams/MapFunctionLambdaExample.java index ab697ab26e..156df66a8b 100644 --- a/src/main/java/io/confluent/examples/streams/MapFunctionLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/MapFunctionLambdaExample.java @@ -60,7 +60,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.MapFunctionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.MapFunctionLambdaExample
  * }
  * 
* 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}). The already diff --git a/src/main/java/io/confluent/examples/streams/PageViewRegionExample.java b/src/main/java/io/confluent/examples/streams/PageViewRegionExample.java index 6349fde11a..7e11c540bb 100644 --- a/src/main/java/io/confluent/examples/streams/PageViewRegionExample.java +++ b/src/main/java/io/confluent/examples/streams/PageViewRegionExample.java @@ -78,7 +78,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link PageViewRegionExampleDriver}). The @@ -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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver * } * * 5) Inspect the resulting data in the output topic, e.g. via {@code kafka-console-consumer}. diff --git a/src/main/java/io/confluent/examples/streams/PageViewRegionExampleDriver.java b/src/main/java/io/confluent/examples/streams/PageViewRegionExampleDriver.java index 44bbc6f0f8..697d10657c 100644 --- a/src/main/java/io/confluent/examples/streams/PageViewRegionExampleDriver.java +++ b/src/main/java/io/confluent/examples/streams/PageViewRegionExampleDriver.java @@ -49,7 +49,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
  * }
  * 
* You should terminate with {@code Ctrl-C}. diff --git a/src/main/java/io/confluent/examples/streams/PageViewRegionLambdaExample.java b/src/main/java/io/confluent/examples/streams/PageViewRegionLambdaExample.java index 539d23c5ef..44a6d67055 100644 --- a/src/main/java/io/confluent/examples/streams/PageViewRegionLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/PageViewRegionLambdaExample.java @@ -75,7 +75,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link PageViewRegionExampleDriver}). @@ -85,7 +85,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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver * } * * 5) Inspect the resulting data in the output topic, e.g. via {@code kafka-console-consumer}. diff --git a/src/main/java/io/confluent/examples/streams/SecureKafkaStreamsExample.java b/src/main/java/io/confluent/examples/streams/SecureKafkaStreamsExample.java index ce87ffd209..413c09d54b 100644 --- a/src/main/java/io/confluent/examples/streams/SecureKafkaStreamsExample.java +++ b/src/main/java/io/confluent/examples/streams/SecureKafkaStreamsExample.java @@ -100,7 +100,7 @@ * [vagrant@kafka ~]$ mvn clean -DskipTests=true package * * # Now we can start this example application - * [vagrant@kafka ~]$ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \ + * [vagrant@kafka ~]$ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \ * io.confluent.examples.streams.SecureKafkaStreamsExample * } * diff --git a/src/main/java/io/confluent/examples/streams/SessionWindowsExample.java b/src/main/java/io/confluent/examples/streams/SessionWindowsExample.java index c3c076e833..fb0c41ec1a 100644 --- a/src/main/java/io/confluent/examples/streams/SessionWindowsExample.java +++ b/src/main/java/io/confluent/examples/streams/SessionWindowsExample.java @@ -70,7 +70,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.SessionWindowsExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.SessionWindowsExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link SessionWindowsExampleDriver}). The @@ -80,7 +80,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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver * } * * You should see output data similar to: diff --git a/src/main/java/io/confluent/examples/streams/SessionWindowsExampleDriver.java b/src/main/java/io/confluent/examples/streams/SessionWindowsExampleDriver.java index 588631a007..83916d4e44 100644 --- a/src/main/java/io/confluent/examples/streams/SessionWindowsExampleDriver.java +++ b/src/main/java/io/confluent/examples/streams/SessionWindowsExampleDriver.java @@ -42,7 +42,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
  * }
  * 
*/ diff --git a/src/main/java/io/confluent/examples/streams/SumLambdaExample.java b/src/main/java/io/confluent/examples/streams/SumLambdaExample.java index 4ba29b0f9c..67a9d021fc 100644 --- a/src/main/java/io/confluent/examples/streams/SumLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/SumLambdaExample.java @@ -53,7 +53,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.SumLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.SumLambdaExample
  * }
  * 
* 4) Write some input data to the source topic (e.g. via {@link SumLambdaExampleDriver}). The @@ -63,7 +63,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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver * } * * 5) Inspect the resulting data in the output topics, e.g. via {@code kafka-console-consumer}. diff --git a/src/main/java/io/confluent/examples/streams/SumLambdaExampleDriver.java b/src/main/java/io/confluent/examples/streams/SumLambdaExampleDriver.java index 2c17e976d9..d845ea996e 100644 --- a/src/main/java/io/confluent/examples/streams/SumLambdaExampleDriver.java +++ b/src/main/java/io/confluent/examples/streams/SumLambdaExampleDriver.java @@ -42,7 +42,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
  * }
  * 
* You should terminate with {@code Ctrl-C}. diff --git a/src/main/java/io/confluent/examples/streams/TopArticlesExampleDriver.java b/src/main/java/io/confluent/examples/streams/TopArticlesExampleDriver.java index 27f851cfbb..d53e302829 100644 --- a/src/main/java/io/confluent/examples/streams/TopArticlesExampleDriver.java +++ b/src/main/java/io/confluent/examples/streams/TopArticlesExampleDriver.java @@ -52,7 +52,7 @@ * Once packaged you can then run: *
  * {@code
- * java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
+ * java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
  * }
  * 
* diff --git a/src/main/java/io/confluent/examples/streams/TopArticlesLambdaExample.java b/src/main/java/io/confluent/examples/streams/TopArticlesLambdaExample.java index 5dfab25c9a..925355e5f6 100644 --- a/src/main/java/io/confluent/examples/streams/TopArticlesLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/TopArticlesLambdaExample.java @@ -81,7 +81,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link TopArticlesExampleDriver}). @@ -92,7 +92,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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.TopArticlesExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.TopArticlesExampleDriver * } * */ diff --git a/src/main/java/io/confluent/examples/streams/UserRegionLambdaExample.java b/src/main/java/io/confluent/examples/streams/UserRegionLambdaExample.java index 65df4c9b45..ece102685c 100644 --- a/src/main/java/io/confluent/examples/streams/UserRegionLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/UserRegionLambdaExample.java @@ -54,7 +54,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.UserRegionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.UserRegionLambdaExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@code kafka-console-producer}). The already diff --git a/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExample.java b/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExample.java index 53c4296444..7dc0872c97 100644 --- a/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExample.java +++ b/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExample.java @@ -58,7 +58,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link WikipediaFeedAvroExampleDriver}). @@ -69,7 +69,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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver * } * */ diff --git a/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExampleDriver.java b/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExampleDriver.java index 2fa3a815f9..7b5153b9fb 100644 --- a/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExampleDriver.java +++ b/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroExampleDriver.java @@ -45,7 +45,7 @@ * Once packaged you can then run: *
  * {@code
- * java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
+ * java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
  * }
  * 
* diff --git a/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java b/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java index 5e7bcb7780..0a0bb734c1 100644 --- a/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/WikipediaFeedAvroLambdaExample.java @@ -55,7 +55,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroLambdaExample
  * }
  * 
* 4) Write some input data to the source topics (e.g. via {@link WikipediaFeedAvroExampleDriver}). @@ -66,7 +66,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/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver * } * */ diff --git a/src/main/java/io/confluent/examples/streams/WordCountLambdaExample.java b/src/main/java/io/confluent/examples/streams/WordCountLambdaExample.java index 81fbbd0e09..eb53350bc4 100644 --- a/src/main/java/io/confluent/examples/streams/WordCountLambdaExample.java +++ b/src/main/java/io/confluent/examples/streams/WordCountLambdaExample.java @@ -62,7 +62,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.WordCountLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.WordCountLambdaExample
  * }
  * 
* 4) Write some input data to the source topic "streams-plaintext-input" (e.g. via {@code kafka-console-producer}). diff --git a/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesDriver.java b/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesDriver.java index eb1f39d59e..78fef9b13f 100644 --- a/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesDriver.java +++ b/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesDriver.java @@ -36,7 +36,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesDriver
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesDriver
  * }
  * 
* You should terminate with Ctrl-C diff --git a/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java b/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java index 823d480486..d71bcd08d6 100644 --- a/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java +++ b/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java @@ -81,7 +81,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesExample 7070
  * }
  * 
@@ -92,7 +92,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesExample 7071
  * }
  * 
diff --git a/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java b/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java index e1dfbcd6a2..330ba5c394 100644 --- a/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java +++ b/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExample.java @@ -109,7 +109,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExample 7070
  * }
  * 
@@ -120,7 +120,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExample 7071
  * }
  * 
diff --git a/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExampleDriver.java b/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExampleDriver.java index 7e372caaf5..f6157808c6 100644 --- a/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExampleDriver.java +++ b/src/main/java/io/confluent/examples/streams/interactivequeries/kafkamusic/KafkaMusicExampleDriver.java @@ -50,7 +50,7 @@ * Once packaged you can then run: *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExampleDriver
  * }
  * 
diff --git a/src/main/java/io/confluent/examples/streams/microservices/README.md b/src/main/java/io/confluent/examples/streams/microservices/README.md index 91067c4e1a..921f8ed144 100644 --- a/src/main/java/io/confluent/examples/streams/microservices/README.md +++ b/src/main/java/io/confluent/examples/streams/microservices/README.md @@ -34,7 +34,7 @@ Then run the fully-working demo [end-to-end](https://docs.confluent.io/current/t It runs the ecosystem and all the microservices for you including Kafka Connect, Elasticsearch, KSQL and Control Center. To play with this ecosystem the simplest way is to run the tests and fiddle with the code (stand alone execution is only supported in branch 5.0.0+ so go there if you want stand alone or docker support). Each test boots a self-contained Kafka cluster so it's easy to play with different queries and configurations. -The best place to start is [EndToEndTest.java](https://github.com/confluentinc/kafka-streams-examples/blob/7.9.x/src/test/java/io/confluent/examples/streams/microservices/EndToEndTest.java) +The best place to start is [EndToEndTest.java](https://github.com/confluentinc/kafka-streams-examples/blob/7.9.3/src/test/java/io/confluent/examples/streams/microservices/EndToEndTest.java) # Running the Examples: * Requires Java 1.8 diff --git a/src/main/scala/io/confluent/examples/streams/MapFunctionScalaExample.scala b/src/main/scala/io/confluent/examples/streams/MapFunctionScalaExample.scala index 9e5db84727..ecefe86965 100644 --- a/src/main/scala/io/confluent/examples/streams/MapFunctionScalaExample.scala +++ b/src/main/scala/io/confluent/examples/streams/MapFunctionScalaExample.scala @@ -54,7 +54,7 @@ import org.apache.kafka.streams.{KafkaStreams, StreamsConfig} * Once packaged you can then run: * * {{{ - * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.MapFunctionScalaExample + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.MapFunctionScalaExample * }}} * * 4) Write some input data to the source topics (e.g. via `kafka-console-producer`. The already diff --git a/src/main/scala/io/confluent/examples/streams/WordCountScalaExample.scala b/src/main/scala/io/confluent/examples/streams/WordCountScalaExample.scala index dddccf9356..9502dfd001 100644 --- a/src/main/scala/io/confluent/examples/streams/WordCountScalaExample.scala +++ b/src/main/scala/io/confluent/examples/streams/WordCountScalaExample.scala @@ -41,7 +41,7 @@ import org.apache.kafka.streams.{KafkaStreams, StreamsConfig} * Once packaged you can then run: * * {{{ - * $ java -cp target/kafka-streams-examples-7.9.3-0-standalone.jar io.confluent.examples.streams.WordCountLambdaExample + * $ java -cp target/kafka-streams-examples-7.9.3-standalone.jar io.confluent.examples.streams.WordCountLambdaExample * }}} * * 4) Write some input data to the source topic "streams-plaintext-input" (e.g. via `kafka-console-producer`).