fix(kafka sink): remove restriction on data type

closes #18252
vectordotdev · Aug 16, 2023 · 837ebc6 · 837ebc6
1 parent 1b90398
commit 837ebc6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/sinks/kafka/config.rs b/src/sinks/kafka/config.rs
@@ -276,7 +276,7 @@ impl SinkConfig for KafkaSinkConfig {
     fn input(&self) -> Input {
         let requirements = Requirement::empty().optional_meaning("timestamp", Kind::timestamp());
 
-        Input::new(self.encoding.config().input_type() & (DataType::Log | DataType::Metric))
+        Input::new(self.encoding.config().input_type())
             .with_schema_requirement(requirements)
     }