diff --git a/docs/connectors/sources/local-file-source.md b/docs/connectors/sources/local-file-source.md index 3ce8d6ca5..8626c3c42 100644 --- a/docs/connectors/sources/local-file-source.md +++ b/docs/connectors/sources/local-file-source.md @@ -53,7 +53,7 @@ source = FileSource( directory="/path/to/my/topic_folder", format="json", compression="gzip", - as_replay=True, + replay_speed=1.0, ) sdf = app.dataframe(source=source).print(metadata=True) # YOUR LOGIC HERE!