From 736af65c029614556393c9c82f1e64393f32d3bc Mon Sep 17 00:00:00 2001
From: hippalus <habiphakan.isler@gmail.com>
Date: Tue, 7 Jan 2025 10:06:35 +0100
Subject: [PATCH] fix ParseableSinkProcessor.deserialize

---
 src/connectors/kafka/processor.rs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/connectors/kafka/processor.rs b/src/connectors/kafka/processor.rs
index 644b1583..4f447443 100644
--- 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 {