diff --git a/README.md b/README.md index e6b8fbbe05..406c57efdb 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.0.0-0-standalone.jar +# >>> Creates target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar \ +$ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar \ +$ java -cp target/kafka-streams-examples-7.0.0-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 be49ff7763..8bd53ec86d 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -2,7 +2,7 @@ version: '2' services: zookeeper: - image: confluentinc/cp-zookeeper:7.0.x-latest + image: confluentinc/cp-zookeeper:7.0.0 hostname: zookeeper ports: - '32181:32181' @@ -13,7 +13,7 @@ services: - "moby:127.0.0.1" kafka: - image: confluentinc/cp-enterprise-kafka:7.0.x-latest + image: confluentinc/cp-enterprise-kafka:7.0.0 hostname: kafka ports: - '9092:9092' @@ -38,7 +38,7 @@ services: - "moby:127.0.0.1" schema-registry: - image: confluentinc/cp-schema-registry:7.0.x-latest + image: confluentinc/cp-schema-registry:7.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:7.0.x-latest + image: confluentinc/cp-kafka:7.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/kafka-streams-examples:7.0.x-latest + image: confluentinc/kafka-streams-examples:7.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 /usr/share/java/kafka-streams-examples/kafka-streams-examples-7.0.0-0-standalone.jar \ + java -cp /usr/share/java/kafka-streams-examples/kafka-streams-examples-7.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/kafka-streams-examples:7.0.x-latest + image: confluentinc/kafka-streams-examples:7.0.0 hostname: kafka-music-application depends_on: - kafka diff --git a/pom.xml b/pom.xml index c2bdfebe98..a4ede43089 100644 --- a/pom.xml +++ b/pom.xml @@ -7,12 +7,12 @@ io.confluent rest-utils-parent - [7.0.0-0, 7.0.1-0) + 7.0.0 kafka-streams-examples jar - 7.0.0-0 + 7.0.0 Confluent, Inc. @@ -66,7 +66,7 @@ ${project.version}-${docker.os_type} ${confluent.version.range} ${confluent.version.range} - 7.0.0-0 + 7.0.0 diff --git a/src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java b/src/main/java/io/confluent/examples/streams/AnomalyDetectionLambdaExample.java index c01f87c559..28bbad1266 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.0.0-0-standalone.jar io.confluent.examples.streams.AnomalyDetectionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 06e39ba740..f7d400829d 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.0.0-0-standalone.jar io.confluent.examples.streams.ApplicationResetExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.ApplicationResetExample localhost:9092 --reset
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 98b43732eb..6b256e3b8e 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.0.0-0-standalone.jar io.confluent.examples.streams.GlobalKTablesExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.GlobalKTablesAndStoresExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 e0480311a4..f450245ff2 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.0.0-0-standalone.jar io.confluent.examples.streams.JsonToAvroExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.JsonToAvroExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 49ec537c21..58abb194e5 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.0.0-0-standalone.jar io.confluent.examples.streams.JsonToAvroExampleDriver
+ * java -cp target/kafka-streams-examples-7.0.0-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 efc59aa794..e35f81b516 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.0.0-0-standalone.jar io.confluent.examples.streams.MapFunctionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 66b24934b0..f2aa9559ae 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.0.0-0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 fbc57087b9..de2b77b262 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.0.0-0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 6c482d5335..6cab0625fa 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.0.0-0-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 870c349228..aceebd8074 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.0.0-0-standalone.jar \ + * [vagrant@kafka ~]$ java -cp target/kafka-streams-examples-7.0.0-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 5275949eaa..14a245b7f0 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.0.0-0-standalone.jar io.confluent.examples.streams.SessionWindowsExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 2a3eb464eb..bd085b43c1 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.0.0-0-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 d5a8cfc0b0..5a42497371 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.0.0-0-standalone.jar io.confluent.examples.streams.SumLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 0cf24ff877..30ce201d1d 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.0.0-0-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 28e8181420..324b0ab41e 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.0.0-0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
+ * java -cp target/kafka-streams-examples-7.0.0-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 182ba37c0e..e554f3a443 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.0.0-0-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.TopArticlesExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 d9e33e3e91..410b09a294 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.0.0-0-standalone.jar io.confluent.examples.streams.UserRegionLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 87c0366c82..467de6b06a 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.0.0-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 2e377ea245..ad028dd8a5 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.0.0-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
+ * java -cp target/kafka-streams-examples-7.0.0-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 ad7d7352cd..348b7b29e5 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.0.0-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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.0.0-0-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver + * $ java -cp target/kafka-streams-examples-7.0.0-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 5863d04acc..71ae5dc9c9 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.0.0-0-standalone.jar io.confluent.examples.streams.WordCountLambdaExample
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 51513e210b..8bd310f5d8 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.0.0-0-standalone.jar io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesDriver
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 2f39a4d506..3725641cfe 100644 --- a/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java +++ b/src/main/java/io/confluent/examples/streams/interactivequeries/WordCountInteractiveQueriesExample.java @@ -83,7 +83,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.0.0-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.0.0-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesExample 7070
  * }
  * 
@@ -94,7 +94,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.0.0-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 18a5794eac..e319fe6376 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 @@ -110,7 +110,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.0.0-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.0.0-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExample 7070
  * }
  * 
@@ -121,7 +121,7 @@ * *
  * {@code
- * $ java -cp target/kafka-streams-examples-7.0.0-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.0.0-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 b184b9cb34..7cf81ab8f1 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.0.0-0-standalone.jar \
+ * $ java -cp target/kafka-streams-examples-7.0.0-standalone.jar \
  *      io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExampleDriver
  * }
  * 
diff --git a/src/main/scala/io/confluent/examples/streams/MapFunctionScalaExample.scala b/src/main/scala/io/confluent/examples/streams/MapFunctionScalaExample.scala index 3b19bb9bd5..f44178356c 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.0.0-0-standalone.jar io.confluent.examples.streams.MapFunctionScalaExample + * $ java -cp target/kafka-streams-examples-7.0.0-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 6058accbd7..ee4c2ce1a2 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.0.0-0-standalone.jar io.confluent.examples.streams.WordCountLambdaExample + * $ java -cp target/kafka-streams-examples-7.0.0-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`).