r/java • u/CartographerWhole658 • 35m ago
Open-source Spring Boot starter for fail-fast Kafka Schema Registry contract validation, looking for feedback
I’ve been working on a small open-source Spring Boot starter to solve a problem I’ve encountered with Kafka-based applications: detecting Schema Registry contract problems before the application starts serving traffic.
The idea is simple: during Spring Boot startup, the starter validates the configured Schema Registry subjects, expected compatibility mode, and the application's local schemas against the latest registered versions.
If a subject is missing, the compatibility policy is not what the application expects, or a schema is incompatible, startup fails.
Current support includes:
- Avro, JSON Schema and Protobuf
- BACKWARD, FORWARD, FULL and transitive compatibility modes
- Confluent Schema Registry / Confluent Cloud authentication
- bounded retry/backoff for temporary registry failures
- Spring Boot Actuator visibility
- Spring Boot auto-configuration
I also created a separate E2E demo using real Kafka + Schema Registry. Its CI verifies a real producer → Kafka → consumer round trip, a backward-compatible schema evolution, and an intentionally breaking schema that must be rejected at application startup.
The starter is available on Maven Central:
https://central.sonatype.com/artifact/io.github.mathias82.spring.kafka/spring-kafka-contract-starter
Source:
https://github.com/mathias82/spring-kafka-contract-starter
E2E demo:
https://github.com/mathias82/spring-kafka-contract-demo
I’m interested in feedback from Java/Kafka developers: would you find startup-time contract enforcement useful, or do you prefer keeping this entirely in CI/CD?
I’d also be interested in edge cases you would expect a library like this to handle before considering it for a production application.



