From f6259751338eff2ce35f98b121bad4dfcf698140 Mon Sep 17 00:00:00 2001
From: Devdutt Shenoi <devdutt@parseable.com>
Date: Sat, 21 Dec 2024 08:25:07 +0530
Subject: [PATCH] fix: incompatibility from merge (#1046)

Fixes type incompatibility that stems from merging #1021 after #981
---
 src/kafka.rs | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/kafka.rs b/src/kafka.rs
index 9322720c6..ba740df8a 100644
--- a/src/kafka.rs
+++ b/src/kafka.rs
@@ -228,7 +228,11 @@ async fn ingest_message(msg: BorrowedMessage<'_>) -> Result<(), KafkaError> {
     let static_schema_flag = STREAM_INFO.get_static_schema_flag(stream_name)?;
 
     let (rb, is_first) = event
-        .into_recordbatch(schema, static_schema_flag, time_partition)
+        .into_recordbatch(
+            &schema,
+            static_schema_flag.as_ref(),
+            time_partition.as_ref(),
+        )
         .map_err(|err| KafkaError::PostError(PostError::CustomError(err.to_string())))?;
 
     event::Event {