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 - -