diff --git a/python/hsfs/engine/python.py b/python/hsfs/engine/python.py
index 68d3adfd6..a4dc65378 100644
--- a/python/hsfs/engine/python.py
+++ b/python/hsfs/engine/python.py
@@ -1493,6 +1493,7 @@ def _write_dataframe_kafka(
         # make sure producer blocks and everything is delivered
         if not feature_group._multi_part_insert:
             producer.flush()
+            del producer
             progress_bar.close()
 
         # start materialization job if not an external feature group, otherwise return None