fix ParseableSinkProcessor.deserialize

hippalus · Jan 7, 2025 · 736af65 · 736af65
1 parent 84135ed
commit 736af65
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/connectors/kafka/processor.rs b/src/connectors/kafka/processor.rs
@@ -20,7 +20,7 @@ use crate::connectors::common::processor::Processor;
 use crate::connectors::kafka::config::BufferConfig;
 use crate::connectors::kafka::{ConsumerRecord, StreamConsumer, TopicPartition};
 use crate::event::format;
-use crate::event::format::{EventFormat, LogSource};
+use crate::event::format::EventFormat;
 use crate::event::Event as ParseableEvent;
 use crate::handlers::http::ingest::create_stream_if_not_exists;
 use crate::metadata::STREAM_INFO;
@@ -70,7 +70,6 @@ impl ParseableSinkProcessor {
                     static_schema_flag.as_ref(),
                     time_partition.as_ref(),
                     schema_version,
-                    &LogSource::Json,
                 )?;
 
                 let p_event = ParseableEvent {