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