From b58e60176ae3b7f390b1fb9c947cf6b4a8918588 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 29 Aug 2023 15:13:23 -0400 Subject: [PATCH] Pruning batch consumer/producer sample app --- README.adoc | 5 +++++ .../README.adoc | 4 ++-- .../mvnw | 0 .../mvnw.cmd | 0 .../pom.xml | 4 ++-- .../java/sample/stream/batch/CloudStreamsFunctionBatch.java | 0 .../src/main/resources/application.yml | 0 confluent-schema-registry-integration/pom.xml | 2 -- 8 files changed, 9 insertions(+), 6 deletions(-) rename {stream-function-batch-producer-consumer => batch-producer-consumer}/README.adoc (94%) rename {stream-function-batch-producer-consumer => batch-producer-consumer}/mvnw (100%) rename {stream-function-batch-producer-consumer => batch-producer-consumer}/mvnw.cmd (100%) rename {stream-function-batch-producer-consumer => batch-producer-consumer}/pom.xml (97%) rename {stream-function-batch-producer-consumer => batch-producer-consumer}/src/main/java/sample/stream/batch/CloudStreamsFunctionBatch.java (100%) rename {stream-function-batch-producer-consumer => batch-producer-consumer}/src/main/resources/application.yml (100%) diff --git a/README.adoc b/README.adoc index 422e2db..408a9a2 100644 --- a/README.adoc +++ b/README.adoc @@ -22,3 +22,8 @@ You can find more details at link:confluent-schema-registry-integration/README.a These samples show how Spring Cloud Stream Schema Registry can help with schema evolution use cases. More details are available at link:spring-cloud-stream-schema-registry-integration/README.adoc/[README]. +==== Batch Producer Consumer + +This sample app shows how to write batch consumers and producers using spring Cloud Stream and Apache Kafka. +More details are at link:batch-producer-consumer/README.adoc[README]. + diff --git a/stream-function-batch-producer-consumer/README.adoc b/batch-producer-consumer/README.adoc similarity index 94% rename from stream-function-batch-producer-consumer/README.adoc rename to batch-producer-consumer/README.adoc index 9f05b50..aeb8081 100644 --- a/stream-function-batch-producer-consumer/README.adoc +++ b/batch-producer-consumer/README.adoc @@ -1,4 +1,4 @@ -== Spring Function Batch Producer Consumer +== Spring Cloud Stream Batch Producer Consumer This sample application demonstrates a Spring Cloud Stream functional interface implementation of batch consuming and batch producing messages. @@ -33,7 +33,7 @@ To build the app simply execute the following command in the base directory: ==== Start the streams app [source,bash] ---- -java -jar target/stream-function-batch-producer-consumer-0.0.1-SNAPSHOT.jar +java -jar target/batch-producer-consumer-0.0.1-SNAPSHOT.jar ---- The application should automatically begin executing. All messages are printed in real-time as received by different parts of the application. diff --git a/stream-function-batch-producer-consumer/mvnw b/batch-producer-consumer/mvnw similarity index 100% rename from stream-function-batch-producer-consumer/mvnw rename to batch-producer-consumer/mvnw diff --git a/stream-function-batch-producer-consumer/mvnw.cmd b/batch-producer-consumer/mvnw.cmd similarity index 100% rename from stream-function-batch-producer-consumer/mvnw.cmd rename to batch-producer-consumer/mvnw.cmd diff --git a/stream-function-batch-producer-consumer/pom.xml b/batch-producer-consumer/pom.xml similarity index 97% rename from stream-function-batch-producer-consumer/pom.xml rename to batch-producer-consumer/pom.xml index 5cb1f6b..0651777 100644 --- a/stream-function-batch-producer-consumer/pom.xml +++ b/batch-producer-consumer/pom.xml @@ -10,9 +10,9 @@ com.example - stream-function-batch-producer-consumer + batch-producer-consumer 0.0.1 - stream-function-batch-producer-consumer + batch-producer-consumer Sample app using stream functions with batch producer and consumer using kafka 17 diff --git a/stream-function-batch-producer-consumer/src/main/java/sample/stream/batch/CloudStreamsFunctionBatch.java b/batch-producer-consumer/src/main/java/sample/stream/batch/CloudStreamsFunctionBatch.java similarity index 100% rename from stream-function-batch-producer-consumer/src/main/java/sample/stream/batch/CloudStreamsFunctionBatch.java rename to batch-producer-consumer/src/main/java/sample/stream/batch/CloudStreamsFunctionBatch.java diff --git a/stream-function-batch-producer-consumer/src/main/resources/application.yml b/batch-producer-consumer/src/main/resources/application.yml similarity index 100% rename from stream-function-batch-producer-consumer/src/main/resources/application.yml rename to batch-producer-consumer/src/main/resources/application.yml diff --git a/confluent-schema-registry-integration/pom.xml b/confluent-schema-registry-integration/pom.xml index 783e716..0214898 100644 --- a/confluent-schema-registry-integration/pom.xml +++ b/confluent-schema-registry-integration/pom.xml @@ -20,8 +20,6 @@ confluent-schema-registry-integration-producer2 - -