Crate schema_registry_api
source ·Expand description
Schema registry API
Provide a REST API to call with a schema registry.
Examples
List subjects
use reqwest::Url;
use schema_registry_api::SchemaRegistry;
#[tokio::main]
async fn main() -> anyhow::Result<()> {
// Create a `SchemaRegistry`
let base_url = Url::parse("http://localhost:8081")?;
let sr = SchemaRegistry::build_default(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
use reqwest::Url;
use schema_registry_api::{RegisterSchema, SchemaRegistry};
#[tokio::main]
async fn main() -> anyhow::Result<()> {
// Create a `SchemaRegistry`
let base_url = Url::parse("http://localhost:8081")?;
let sr = SchemaRegistry::build_default(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.
Structs
- An API error
- The compatibility
- The compatibility client
- Compatibility result
- The configuration client
- The compatibility get result
- The mode wrapper
- The subject client
- Register a schema
- Registered schema result
- A Schema payload
- The subject client
- The schema id
- An Schema id error
- A schema reference
- A schema registry client
- An Schema version error
- A subject
- The subject client
- A subject name
- A subject an associated version
Enums
- Compatibility level
- The resource mode
- A schema registry error
- A Schema type
- The schema version
- An subject error