This project aims to showcase how to integrate with a Kafka Cluster using Spring Cloud Stream. It exposes a POST endpoint that allows a client to upload a file, which is then sent to a Kafka topic and consumed by a listener
Please note the focus of this project is not the REST API nor the efficiency of it.
- Spring Boot V2.7
- Java 11
- Spring Cloud Stream Kafka Binder V3
- Spin locally a Kafka Broker on port
9092
- Run the producer app and the consumer app
- Using your favourite REST Client, do
POST http://localhost:8080/image
and pass a file. - Go check the consumer's folder
/resources/files
, you should find the file saved there.