This project demonstrates how to integrate Apache Kafka with the Confluent Schema Registry using Spring Boot, publishing and consuming structured messages in JSON Schema format.
It uses:
- Spring Boot 3.x
- Apache Kafka
- Confluent Schema Registry (7.x)
- JSON Schema with Confluent's serializers
- Java 21
- ✅ JSON Schema registration and validation via Confluent Schema Registry
- ✅ Spring Kafka Producer and Consumer
- ✅ KafkaTemplate integration with schema-aware serialization
- ✅ Minimal configuration with
application.yaml
- ✅ Docker Compose to spin up Kafka and Schema Registry locally
git clone https://github.com/your-username/kafka-schema-spring-boot.git
cd kafka-schema-spring-boot