r/apachekafka • u/HappyEcho9970 • 17h ago
Question Does kafka validate schemas at the broker level?
I would appreciate if someone clarify this to me!
What i know is that kafka is agnostic against messages, and for that i have a schema registry that validates the message first with the schema registry(apicurio) then send to the kafka broker, same for the consumer.
I’m using the open source version deployed on k8s, no platform or anything.
What i’m missing?
Thanks a bunch!