async fn compile_proto(
    id: i32,
    ccsr_client: &ccsr::Client,
) -> Result<CsrSeedCompiledEncoding, anyhow::Error> {
    let (primary_subject, dependency_subjects) =
        ccsr_client.get_subject_and_references_by_id(id).await?;
    compile_proto_from_subjects(primary_subject, dependency_subjects).await
}
/// Collect protobuf message descriptor from CSR and compile the descriptor.
///
/// This reaches out to the Confluent Schema Registry to search for the correct schema
/// for the provided subject (generally a Kafka topic with the `-value` or `-key` suffix)
/// and recursively constructs the encoding.
Collect protobuf message descriptor from CSR and compile the descriptor.
This reaches out to the Confluent Schema Registry to search for the correct schema
for the provided subject (generally a Kafka topic with the `-value` or `-key` suffix)
and recursively constructs the encoding.
Collect protobuf message descriptor from CSR and compile the descriptor . This reaches out to the Confluent Schema Registry to search for the correct schema for the provided subject ( generally a Kafka topic with the ` - value ` or ` - key ` suffix ) and recursively constructs the encoding .
async fn compile_proto(
    id: i32,
    ccsr_client: &ccsr::Client,
) -> Result<CsrSeedCompiledEncoding, anyhow::Error> {
    let (primary_subject, dependency_subjects) =
        ccsr_client.get_subject_and_references_by_id(id).await?;
    compile_proto_from_subjects(primary_subject, dependency_subjects).await
}
async fn compile_proto ( id : i32 , ccsr_client : & ccsr :: Client , ) -> Result < CsrSeedCompiledEncoding , anyhow :: Error > { let ( primary_subject , dependency_subjects ) = ccsr_client . get_subject_and_references_by_id ( id ) . await ? ; compile_proto_from_subjects ( primary_subject , dependency_subjects ) . await }
Collect protobuf message descriptor from CSR and compile the descriptor.
Collect protobuf message descriptor from CSR and compile the descriptor .
id
i32
ccsr_client
&ccsr::Client
id
i32
ccsr_client
&ccsr::Client