diff --git a/arroyo-api/src/pipelines.rs b/arroyo-api/src/pipelines.rs index 497f55647..018aa7c5a 100644 --- a/arroyo-api/src/pipelines.rs +++ b/arroyo-api/src/pipelines.rs @@ -196,7 +196,6 @@ async fn try_register_confluent_schema( .await .map_err(|e| anyhow!("Failed to write schema to schema registry: {}", e))?; - println!("Fetched id = {}", id); avro.schema_id = Some(id as u32); config.format = Some(Format::Avro(avro)) } @@ -211,8 +210,6 @@ async fn try_register_confluent_schema( sink.config = serde_json::to_string(&config).unwrap(); - println!("config = {}", sink.config); - Ok(()) }