diff --git a/sdk/python/feast/data_source.py b/sdk/python/feast/data_source.py
index bc8ebbbd8b..983cd858d3 100644
--- a/sdk/python/feast/data_source.py
+++ b/sdk/python/feast/data_source.py
@@ -92,7 +92,7 @@ def to_proto(self) -> DataSourceProto.KafkaOptions:
         if self.watermark_delay_threshold is not None:
             watermark_delay_threshold = Duration()
             watermark_delay_threshold.FromTimedelta(self.watermark_delay_threshold)
-            
+
         kafka_settings = None
         if self.kafka_settings is not None:
             kafka_settings = self.kafka_settings
diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
index 874fb403b4..e8c984ebff 100644
--- a/sdk/python/feast/infra/contrib/spark_kafka_processor.py
+++ b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
@@ -91,8 +91,8 @@ def _ingest_stream_data(self) -> StreamTable:
         )
 
         if self.data_source.kafka_options.kafka_settings is not None:
-            for k,v in self.data_source.kafka_options.kafka_settings.items():
-                stream_df = stream_df.option(k,v)
+            for k, v in self.data_source.kafka_options.kafka_settings.items():
+                stream_df = stream_df.option(k, v)
 
         stream_df = stream_df.load().selectExpr("CAST(value AS STRING)")