mirror of
https://github.com/wahyd4/spring-cloud-stream-samples.git
synced 2026-08-08 21:06:34 +10:00
Renaming kafka streams schema registry sample components
This commit is contained in:
@@ -1,7 +1,7 @@
|
||||
== Spring Cloud Stream, Kafka Streams and Schema Evolution in Action with Confluent Schema Registry Server!
|
||||
|
||||
This repo includes three Spring Boot applications to demonstrate Schema Evolution using Spring Cloud Stream Kafka and Kafka Streams binders support.
|
||||
Producer V1 (`kafka-streams-confluent-producer1`), Producer V2 (`kafka-streams-confluent-producer2`), and Consumer (`kafka-streams-confluent-consumer`) are included in this project.
|
||||
Producer V1 (`custom-confluent-producer1`), Producer V2 (`custom-confluent-producer2`), and Consumer (`kafka-streams-confluent-consumer`) are included in this project.
|
||||
|
||||
Both producers are standard spring cloud stream sources that use the kafka binder.
|
||||
They both skip the framework provided serialization on the outbound and relies on Kafka's native serialization mechanism.
|
||||
@@ -34,15 +34,15 @@ In order to run this sample, you need to set compatibility to `NONE` on Confluen
|
||||
----
|
||||
java -jar kafka-streams-confluent-consumer/target/kafka-streams-confluent-consumer-0.0.1-SNAPSHOT.jar
|
||||
----
|
||||
- Start `kafka-streams-confluent-producer1` on another terminal session
|
||||
- Start `custom-confluent-producer1` on another terminal session
|
||||
[source,bash]
|
||||
----
|
||||
java -jar kafka-streams-confluent-producer1/target/kafka-streams-confluent-producer1-0.0.1-SNAPSHOT.jar
|
||||
java -jar custom-confluent-producer1/target/custom-confluent-producer1-0.0.1-SNAPSHOT.jar
|
||||
----
|
||||
- Start `kafka-streams-confluent-producer2` on another terminal session
|
||||
- Start `custom-confluent-producer2` on another terminal session
|
||||
[source,bash]
|
||||
----
|
||||
java -jar kafka-streams-confluent-producer1/target/kafka-streams-confluent-producer1-0.0.1-SNAPSHOT.jar
|
||||
java -jar custom-confluent-producer1/target/custom-confluent-producer1-0.0.1-SNAPSHOT.jar
|
||||
----
|
||||
|
||||
=== Sample Data
|
||||
|
||||
+3
-3
@@ -2,11 +2,11 @@
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<artifactId>kafka-streams-confluent-producer1</artifactId>
|
||||
<artifactId>custom-confluent-producer1</artifactId>
|
||||
<version>0.0.1-SNAPSHOT</version>
|
||||
<packaging>jar</packaging>
|
||||
<name>kafka-streams-confluent-producer1</name>
|
||||
<description>Kafka Streams Confluent Producer1</description>
|
||||
<name>custom-confluent-producer1</name>
|
||||
<description>Custom Confluent Producer1</description>
|
||||
|
||||
<parent>
|
||||
<groupId>io.spring.cloud.stream.sample</groupId>
|
||||
+3
-3
@@ -2,11 +2,11 @@
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<artifactId>kafka-streams-confluent-producer2</artifactId>
|
||||
<artifactId>custom-confluent-producer2</artifactId>
|
||||
<version>0.0.1-SNAPSHOT</version>
|
||||
<packaging>jar</packaging>
|
||||
<name>kafka-streams-confluent-producer2</name>
|
||||
<description>Kafka Streams Confluent Producer2</description>
|
||||
<name>custom-confluent-producer2</name>
|
||||
<description>Custom Confluent Producer2</description>
|
||||
|
||||
<parent>
|
||||
<groupId>io.spring.cloud.stream.sample</groupId>
|
||||
@@ -9,8 +9,8 @@
|
||||
<description>Kafka Streams Schema Evolution Sample</description>
|
||||
|
||||
<modules>
|
||||
<module>kafka-streams-confluent-producer1</module>
|
||||
<module>kafka-streams-confluent-producer2</module>
|
||||
<module>custom-confluent-producer1</module>
|
||||
<module>custom-confluent-producer2</module>
|
||||
<module>kafka-streams-confluent-consumer</module>
|
||||
</modules>
|
||||
</project>
|
||||
|
||||
Reference in New Issue
Block a user