diff --git a/settings.py b/settings.py index db46a55..a34f1f8 100644 --- a/settings.py +++ b/settings.py @@ -18,7 +18,7 @@ class Config: 'auto_commit_interval_ms': 10000, # 每个游戏不一样 - 'group_id': 'xiangsu_consumer_group' + 'group_id': 'xiangsu_group' } KAFKA_PRODUCER_CONF = { 'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],