Struct SchemaRegistrationBuilder 

pub struct SchemaRegistrationBuilder<'a> { /* private fields */ }

Builder for schema registration with fluent API

This builder provides a convenient way to register schemas in the Danube Schema Registry. It supports all schema types (Avro, Protobuf, JSON Schema, etc.) and handles version management.

Example

use danube_client::{DanubeClient, SchemaType};

let client = DanubeClient::builder()
    .service_url("http://localhost:6650")
    .build()
    .await?;

let mut schema_client = client.schema_registry_client();

// Register an Avro schema
let schema_id = schema_client
    .register_schema("user-events-value")
    .with_type(SchemaType::Avro)
    .with_schema_data(avro_schema_bytes)
    .execute()
    .await?;

println!("Schema registered with ID: {}", schema_id);

Schema Versioning

The registry automatically handles versioning:

• If the schema definition is new, a new version is created
• If the schema definition already exists, the existing schema_id and version are returned
• Compatibility checks are performed based on the subject’s compatibility mode

Implementations

impl<'a> SchemaRegistrationBuilder<'a>

pub fn with_type(self, schema_type: SchemaType) -> Self

Set the schema type

Example

use danube_client::SchemaType;

.with_type(SchemaType::Avro)

pub fn with_schema_data(self, data: impl Into<Vec<u8>>) -> Self

Set the schema data (raw schema content)

pub async fn execute(self) -> Result<u64>

Execute the schema registration