diff --git a/python/hsfs/engine/python.py b/python/hsfs/engine/python.py
index 34fc1ffd5..68d3adfd6 100644
--- a/python/hsfs/engine/python.py
+++ b/python/hsfs/engine/python.py
@@ -1511,7 +1511,7 @@ def _write_dataframe_kafka(
                 topic_name=feature_group._online_topic_name,
                 feature_store_id=feature_group.feature_store_id,
                 offline_write_options=offline_write_options,
-                high=True,
+                high=False,
             )
             now = datetime.now(timezone.utc)
             feature_group.materialization_job.run(