There was an error fetching the commit references. Please try again later.
Added kafka with cloud stream (producer and consumer)
parents
Showing
- .gitignore 33 additions, 0 deletions.gitignore
- .mvn/wrapper/MavenWrapperDownloader.java 117 additions, 0 deletions.mvn/wrapper/MavenWrapperDownloader.java
- .mvn/wrapper/maven-wrapper.jar 0 additions, 0 deletions.mvn/wrapper/maven-wrapper.jar
- .mvn/wrapper/maven-wrapper.properties 2 additions, 0 deletions.mvn/wrapper/maven-wrapper.properties
- mvnw 310 additions, 0 deletionsmvnw
- mvnw.cmd 182 additions, 0 deletionsmvnw.cmd
- pom.xml 143 additions, 0 deletionspom.xml
- src/main/java/avro/Product.java 631 additions, 0 deletionssrc/main/java/avro/Product.java
- src/main/java/avro/ProductKey.java 315 additions, 0 deletionssrc/main/java/avro/ProductKey.java
- src/main/java/com/example/CloudStreamKafkaExampleApplication.java 19 additions, 0 deletions.../java/com/example/CloudStreamKafkaExampleApplication.java
- src/main/java/com/example/config/SchemaRegistryConfig.java 18 additions, 0 deletionssrc/main/java/com/example/config/SchemaRegistryConfig.java
- src/main/java/com/example/consumer/Consumer.java 21 additions, 0 deletionssrc/main/java/com/example/consumer/Consumer.java
- src/main/java/com/example/controller/Controller.java 29 additions, 0 deletionssrc/main/java/com/example/controller/Controller.java
- src/main/java/com/example/producer/Producer.java 38 additions, 0 deletionssrc/main/java/com/example/producer/Producer.java
- src/main/resources/application.yml 29 additions, 0 deletionssrc/main/resources/application.yml
- src/main/resources/product-key-schema.avsc 17 additions, 0 deletionssrc/main/resources/product-key-schema.avsc
- src/main/resources/product-value-schema.avsc 14 additions, 0 deletionssrc/main/resources/product-value-schema.avsc
- src/test/java/com/example/CloudStreamKafkaExampleApplicationTests.java 13 additions, 0 deletions.../com/example/CloudStreamKafkaExampleApplicationTests.java
Please register or sign in to comment