Apply suggestions from code review

Co-authored-by: Matthias Wahl <[email protected]> Signed-off-by: Heinz N. Gies <[email protected]>
tremor-rs · Oct 6, 2023 · 82b0c07 · 82b0c07
1 parent c8e5012
commit 82b0c07
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/preprocessor.rs b/src/preprocessor.rs
@@ -83,7 +83,7 @@ pub fn lookup_with_config(config: &PreprocessorConfig) -> Result<Box<dyn Preproc
         "gelf-chunking" => Ok(Box::<gelf_chunking::GelfChunking>::default()),
         "ingest-ns" => Ok(Box::<ingest_ns::ExtractIngestTs>::default()),
         "length-prefixed" => Ok(Box::<length_prefixed::LengthPrefixed>::default()),
-        "schema-refistry" => {
+        "schema-registry" => {
             Ok(Box::<kafka_schema_registry_prefix::SchemaRegistryPrefix>::default())
         }
         "textual-length-prefixed" => {

diff --git a/src/preprocessor/kafka_schema_registry_prefix.rs b/src/preprocessor/kafka_schema_registry_prefix.rs
@@ -22,7 +22,7 @@ use value_trait::Mutable;
 pub(crate) struct SchemaRegistryPrefix {}
 impl Preprocessor for SchemaRegistryPrefix {
     fn name(&self) -> &str {
-        "schema-refistry"
+        "schema-registry"
     }
 
     fn process(
@@ -44,7 +44,7 @@ impl Preprocessor for SchemaRegistryPrefix {
             meta.insert("schema_id", schema)?;
             Ok(vec![(d.to_vec(), meta)])
         } else {
-            Err("Extract Ingest Ts Preprocessor: < 8 byte".into())
+            Err("Kafka schema registry Preprocessor: < 8 byte".into())
         }
     }
 }