update caller for create stream

nikhilsinhaparseable · nikhilsinhaparseable · commit 5ae6366f7496 · 2025-06-18T02:13:12.000-04:00
diff --git a/src/connectors/kafka/processor.rs b/src/connectors/kafka/processor.rs
@@ -55,6 +55,7 @@ impl ParseableSinkProcessor {
             .create_stream_if_not_exists(
                 stream_name,
                 StreamType::UserDefined,
+                None,
                 vec![log_source_entry],
             )
             .await?;

Original file line number	Diff line number	Diff line change
`@@ -55,6 +55,7 @@ impl ParseableSinkProcessor {`
`55`	`55`	`.create_stream_if_not_exists(`
`56`	`56`	`stream_name,`
`57`	`57`	`StreamType::UserDefined,`
	`58`	`+ None,`
`58`	`59`	`vec![log_source_entry],`
`59`	`60`	`)`
`60`	`61`	`.await?;`