Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >

Atlas Stream Processing Support for Schema Registry and Avro

January 14, 2026

What it is: Atlas Stream Processing now integrates with Confluent Schema Registry for Avro message formats, enabling automatic schema validation for streaming data. Consumers fetch schemas from the registry to serialize messages, while producers deserialize messages and validate them against registered schema definitions. This native integration supports schema evolution and ensures data integrity across your streaming pipelines.  

Who it’s for: This feature is for development and platform engineering teams at medium-to-large established companies who utilize Schema Registry and Avro as industry standards for schema management and governance. It is particularly valuable for architects and data engineers maintaining data quality and performance across complex Kafka pipelines without re-engineering existing infrastructure.

Why it matters: Native Schema Registry support eliminates the migration barrier from Avro to JSON, removing the engineering effort that previously blocked Atlas Stream Processing use. Teams benefit from near real-time schema validation and improved data integrity without custom code or infrastructure changes.

Related Content

Docs

Schema Registry Connection Type

Docs

Source Stage for Schema Registry with Kafka

Docs

Emit Stage for Schema Registry with Kafka