Files

Building Applications Using Spring JDBC 5
HibernateSpringBootEntityListener
REST_Microservices_with_Spring_Boot_Maven_JPA_and_Docker
Spring Data 2022 Fundamentals
Spring Framework 4 Spring Data JPA
Spring Framework Spring Data MongoDB 2
Spring-Boot-3
Spring-Boot-JPA-REST-complete-demo
Spring-events
application-event-example
circuit-breaker-pattern
decrypt-jwt-master
event-carried-state-transfer
expense-tracker-app
inject-into-entity-listener-master
jpa-dynamic-update-demo
kafka-producer-consumer-json-schema
mockito-testing
mongodb-aggregation-pipeline-reactive-spring-data
reactive-mongo-crud
reactive-mongodb-tailable-cursor
redis-pub-sub-demo
redis-stream
redis-transaction
retry-pattern
sample-spring-redis
spring-batch-async-processing
spring-batch-file-upload
spring-boot-batch-thymleaf-demo
spring-boot-crud-example
spring-boot-crud-mysql-demo
spring-boot-crud-open-api
spring-boot-elasticsearch-demo
spring-boot-file-upload-download
spring-boot-flyway
spring-boot-jasper-demo
spring-boot-jasypt
spring-boot-jwt-authentication
spring-boot-jwt
spring-boot-multiple-datasource-master
spring-boot-mysql-docker-compose
spring-boot-pagination-sorting
spring-boot-rabbitmq-example
spring-boot-thymeleaf-bookstore
spring-boot-thymeleaf-student-mgmt
spring-boot-thymeleaf
spring-cloud-stream-demo-vins
- kafka-consumer
- kafka-processor
- kafka-producer
- readme.md
spring-cloud-stream-demo
spring-cloud-stream-process-demo
spring-cloud-stream-rabbitmq-pro-con
spring-data-jpa-querydsl
spring-framework-spel
spring-security-jwt-example
spring-security-oauth-facebook
spring-webflux-error-handling
spring-webflux-reactive-rest-api-demo
spring-webflux-redis
spring-webflux-streaming
spring-webflux-validation
spring-webflux-webclient
spring-xml-beans-kafka-prod-cons
spring-xml-kafka-consumer-example
spring-xml-kafka-consumer-exception-handling
spring-xml-kafka-exception-handling
spring-xml-kafka-json-pro-con
springboot-blog-rest-api-ramesh-f
springboot-docker-demo
springboot-rabbitmq-example
springboot-restful-webservices
springboot-webflux-demo
sse-server-sent-event
timeout-pattern
webclient-feign
webflux-file-upload
webflux-scatter-gather
webflux-websocket
xml-project-to-create-diff-fields-sequencing
.DS_Store

spring-cloud-stream-demo-vins

Name		Name	Last commit message	Last commit date
parent directory ..
kafka-consumer		kafka-consumer
kafka-processor		kafka-processor
kafka-producer		kafka-producer
readme.md		readme.md

readme.md

Spring Cloud Stream Demo

I used confluent kafka, since attached docker-compose (kafka-producer) was giving some issues.

confluent local services start
The local commands are intended for a single-node development environment only,
NOT for production usage. https://docs.confluent.io/current/cli/index.html

Using CONFLUENT_CURRENT: /var/folders/kn/4wr9__651l37hckxvnnwt4hh0000gn/T/confluent.467287
Starting ZooKeeper
ZooKeeper is [UP]
Starting Kafka
Kafka is [UP]
Starting Schema Registry
Schema Registry is [UP]
Starting Kafka REST
Kafka REST is [UP]
Starting Connect
Connect is [UP]
Starting ksqlDB Server
ksqlDB Server is [UP]
Starting Control Center
Control Center is [UP]

Processor logs

Consumer logs