Skip to content

G
gm_strategy_cvr
Commit 17b9af1d authored by 赵威's avatar 赵威
Browse files
Options

try offset

parent 4d6d7874
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
src/online_prediction.py
View file @ 17b9af1d
...@@ -13,7 +13,7 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac ...@@ -13,7 +13,7 @@ def consume_kafka(device_dict, diary_dict, tractate_dict, diary_predict_fn, trac
consumer = KafkaConsumer(bootstrap_servers="172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092", consumer = KafkaConsumer(bootstrap_servers="172.16.44.25:9092,172.16.44.31:9092,172.16.44.45:9092",
group_id="essm_online_prediction", group_id="essm_online_prediction",
enable_auto_commit=True, enable_auto_commit=True,
auto_offset_reset="latest", auto_offset_reset="earliest",
auto_commit_interval_ms=1000) auto_commit_interval_ms=1000)
consumer.subscribe(["gm-portrait-update-device"]) consumer.subscribe(["gm-portrait-update-device"])
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment