Schema registry API

Provide a REST API to call with a schema registry.

Examples

List subjects

```rust, norun use reqwest::Url; use schemaregistry_api::SchemaRegistry;

[tokio::main]

async fn main() -> anyhow::Result<()> { // Create a SchemaRegistry let baseurl = Url::parse("http://localhost:8081")?; let sr = SchemaRegistry::builddefault(base_url)?;

// List subjects
let subjects = sr.subject().list(None, None).await?;

if subjects.is_empty() {
    println!("No subject found");
}
for subject in &subjects {
    println!("Found subject '{subject}'");
}
Ok(())

} ```

Register a schema

```rust, norun use reqwest::Url; use schemaregistry_api::{RegisterSchema, SchemaRegistry};

[tokio::main]

async fn main() -> anyhow::Result<()> { // Create a SchemaRegistry let baseurl = Url::parse("http://localhost:8081")?; let sr = SchemaRegistry::builddefault(base_url)?;

// Create a subject
let subject = "a-topic-value".parse()?;
// Create the `RegisterSchema`
let schema = RegisterSchema {
    schema: include_str!("../tests/assets/a_record.avsc").to_string(),
    ..Default::default()
};

// Register the schema for the subject
let registered_schema = sr.subject().new_version(&subject, &schema, None).await?;
// Get the schema id
let schema_id = registered_schema.id;

println!("The schema #{schema_id} is registered for subject '{subject}'");
Ok(())

} ```

License

Licensed under either of

• Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
• MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.