Skip to content

Commit

Permalink
Set Confluent to 5.0.4, Kafka to 2.0.1-cp8.
Browse files Browse the repository at this point in the history
  • Loading branch information
ConfluentJenkins committed May 14, 2020
1 parent 82f17ae commit 071cd13
Show file tree
Hide file tree
Showing 30 changed files with 50 additions and 50 deletions.
6 changes: 3 additions & 3 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -271,15 +271,15 @@ Kafka Streams examples via:
#
$ mvn clean package
# >>> Creates target/kafka-streams-examples-5.0.3-standalone.jar
# >>> Creates target/kafka-streams-examples-5.0.4-standalone.jar
```
You can now run the example applications as follows:
```shell
# Run an example application from the standalone jar.
# Here: `WordCountLambdaExample`
$ java -cp target/kafka-streams-examples-5.0.3-standalone.jar \
$ java -cp target/kafka-streams-examples-5.0.4-standalone.jar \
io.confluent.examples.streams.WordCountLambdaExample
```
Expand All @@ -295,7 +295,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-5.0.3-standalone.jar \
$ java -cp target/kafka-streams-examples-5.0.4-standalone.jar \
-Dlog4j.configuration=file:src/main/resources/log4j.properties \
io.confluent.examples.streams.WordCountLambdaExample
```
Expand Down
14 changes: 7 additions & 7 deletions docker-compose.yml
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
version: '2'
services:
zookeeper:
image: confluentinc/cp-zookeeper:5.0.4-SNAPSHOT
image: confluentinc/cp-zookeeper:5.0.4
hostname: zookeeper
ports:
- '32181:32181'
Expand All @@ -13,7 +13,7 @@ services:
- "moby:127.0.0.1"

kafka:
image: confluentinc/cp-enterprise-kafka:5.0.4-SNAPSHOT
image: confluentinc/cp-enterprise-kafka:5.0.4
hostname: kafka
ports:
- '9092:9092'
Expand All @@ -39,7 +39,7 @@ services:
- "moby:127.0.0.1"

schema-registry:
image: confluentinc/cp-schema-registry:5.0.4-SNAPSHOT
image: confluentinc/cp-schema-registry:5.0.4
hostname: schema-registry
depends_on:
- zookeeper
Expand All @@ -55,7 +55,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:5.0.4-SNAPSHOT
image: confluentinc/cp-kafka:5.0.4
depends_on:
- kafka
hostname: kafka-create-topics
Expand All @@ -79,7 +79,7 @@ services:

# Continuously generates input data for the Kafka Music application.
kafka-music-data-generator:
image: confluentinc/kafka-streams-examples:5.0.4-SNAPSHOT
image: confluentinc/kafka-streams-examples:5.0.4
hostname: kafka-music-data-generator
depends_on:
- kafka
Expand All @@ -90,7 +90,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-5.0.0-standalone.jar \
java -cp /usr/share/java/kafka-streams-examples/kafka-streams-examples-5.0.4-standalone.jar \
io.confluent.examples.streams.interactivequeries.kafkamusic.KafkaMusicExampleDriver \
kafka:29092 http://schema-registry:8081'"
environment:
Expand All @@ -104,7 +104,7 @@ services:

# Runs the Kafka Music application.
kafka-music-application:
image: confluentinc/kafka-streams-examples:5.0.4-SNAPSHOT
image: confluentinc/kafka-streams-examples:5.0.4
hostname: kafka-music-application
depends_on:
- kafka
Expand Down
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
<parent>
<groupId>io.confluent</groupId>
<artifactId>rest-utils-parent</artifactId>
<version>5.0.4-SNAPSHOT</version>
<version>5.0.4</version>
</parent>

<artifactId>kafka-streams-examples</artifactId>
Expand Down Expand Up @@ -54,7 +54,7 @@
<docker.skip-build>false</docker.skip-build>
<docker.skip-test>false</docker.skip-test>
<java.version>1.8</java.version>
<licenses.version>5.0.4-SNAPSHOT</licenses.version>
<licenses.version>5.0.4</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>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.AnomalyDetectionLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.ApplicationResetExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.ApplicationResetExample
* }
* </pre>
* 4) Write some input data to the source topic (e.g. via {@code kafka-console-producer}).
Expand Down Expand Up @@ -113,7 +113,7 @@
* Thus, restart the application via:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.ApplicationResetExample localhost:9092 --reset
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.ApplicationResetExample localhost:9092 --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".
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.GlobalKTablesExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.GlobalKTablesExample
* }
* </pre>
* 4) Write some input data to the source topics (e.g. via {@link GlobalKTablesExampleDriver}). The
Expand All @@ -82,7 +82,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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
* }
* </pre>
* <p>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.GlobalKTablesExampleDriver
* }
* </pre>
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.MapFunctionLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
* }
* </pre>
* 4) Write some input data to the source topics (e.g. via {@link PageViewRegionExampleDriver}). The
Expand All @@ -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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
* }
* </pre>
* 5) Inspect the resulting data in the output topic, e.g. via {@code kafka-console-consumer}.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
* }
* </pre>
* You should terminate with {@code Ctrl-C}.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.PageViewRegionLambdaExample
* }
* </pre>
* 4) Write some input data to the source topics (e.g. via {@link PageViewRegionExampleDriver}).
Expand All @@ -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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.PageViewRegionExampleDriver
* }
* </pre>
* 5) Inspect the resulting data in the output topic, e.g. via {@code kafka-console-consumer}.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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-5.0.0-SNAPSHOT-standalone.jar \
* [vagrant@kafka ~]$ java -cp target/kafka-streams-examples-5.0.4-standalone.jar \
* io.confluent.examples.streams.SecureKafkaStreamsExample
* }
* </pre>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.SessionWindowsExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.SessionWindowsExample
* }
* </pre>
* 4) Write some input data to the source topics (e.g. via {@link SessionWindowsExampleDriver}). The
Expand All @@ -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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
* }
* </pre>
* You should see output data similar to:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.SessionWindowsExampleDriver
* }
* </pre>
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.SumLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.SumLambdaExample
* }
* </pre>
* 4) Write some input data to the source topic (e.g. via {@link SumLambdaExampleDriver}). The
Expand All @@ -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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
* }
* </pre>
* 5) Inspect the resulting data in the output topics, e.g. via {@code kafka-console-consumer}.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.SumLambdaExampleDriver
* }
* </pre>
* You should terminate with {@code Ctrl-C}.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
* java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
* }
* </pre>
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.TopArticlesLambdaExample
* }
* </pre>
* 4) Write some input data to the source topics (e.g. via {@link TopArticlesExampleDriver}).
Expand All @@ -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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.TopArticlesExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.TopArticlesExampleDriver
* }
* </pre>
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.UserRegionLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExample
* }
* </pre>
* 4) Write some input data to the source topics (e.g. via {@link WikipediaFeedAvroExampleDriver}).
Expand All @@ -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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
* }
* </pre>
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
* java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
* }
* </pre>
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroLambdaExample
* }
* </pre>
* 4) Write some input data to the source topics (e.g. via {@link WikipediaFeedAvroExampleDriver}).
Expand All @@ -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-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.WikipediaFeedAvroExampleDriver
* }
* </pre>
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.WordCountLambdaExample
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.WordCountLambdaExample
* }
* </pre>
* 4) Write some input data to the source topic "streams-plaintext-input" (e.g. via {@code kafka-console-producer}).
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@
* Once packaged you can then run:
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesDriver
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesDriver
* }
* </pre>
* You should terminate with Ctrl-C
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@
*
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar \
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar \
* io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesExample 7070
* }
* </pre>
Expand All @@ -93,7 +93,7 @@
*
* <pre>
* {@code
* $ java -cp target/kafka-streams-examples-5.0.0-SNAPSHOT-standalone.jar \
* $ java -cp target/kafka-streams-examples-5.0.4-standalone.jar \
* io.confluent.examples.streams.interactivequeries.WordCountInteractiveQueriesExample 7071
* }
* </pre>
Expand Down
Loading

0 comments on commit 071cd13

Please sign in to comment.