update interval

e6e70d35 · 赵威 · 621dab80 · e6e70d35
Commit e6e70d35 authored Aug 07, 2020 by 赵威
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 1 deletion

online_prediction.py src/online_prediction.py +1 -1

No files found.
--- a/src/online_prediction.py
+++ b/src/online_prediction.py
@@ -14,7 +14,7 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
                             group_id="essm_online_prediction",
                             enable_auto_commit=True,
                             auto_offset_reset="latest",
-                             auto_commit_interval_ms=500000)
+                             auto_commit_interval_ms=5000)

    consumer.subscribe(["gm-portrait-update-device"])