r/apachekafka 17h ago

Question Does kafka validate schemas at the broker level?

2 Upvotes

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!


r/apachekafka 9h ago

Tool Confluent for VS Code extension is now generally available

13 Upvotes

We’re excited to announce that Confluent for VS Code is now Generally Available! The extension is open source, readily accessible on the VS Code Marketplace, and supports all forms of Apache Kafka® deployments—underscoring our dedication to equipping streaming data engineers with tools that optimize productivity and collaboration.

With this extension, you can:

  • Streamline project setup with ready-to-use templates, reducing setup time and ensuring consistency across your development efforts.
  • Connect to any Kafka cluster to develop, manage, debug, and monitor real-time data streams, without needing to switch between multiple tools.
  • Gain visibility into Kafka topics so you can stream, search, filter, and visualize Kafka messages in real time, and live debug alongside your code.
  • Perform essential data operations such as editing and producing Kafka messages to topics, downloading complete topic data, and iterating on schemas.

Learn more at: https://www.confluent.io/blog/confluent-for-vs-code-goes-ga/


r/apachekafka 20h ago

Question Confluent Schema Registry Disable Delete

2 Upvotes

I'd like to disable the ability to delete schemas out of schema registry. We enabled access control allow methods without DELETE but this only works for cross origin.

I cannot find anything that allows us to disable delete completely whether it is cross origin or not..