diff --git a/settings.py b/settings.py index a34f1f8..0a7b0c8 100644 --- a/settings.py +++ b/settings.py @@ -8,7 +8,7 @@ class Config: 'send_receive_timeout': 30} # 每个游戏不一样 游戏上报 kafka 主题 - SUBSCRIBE_TOPIC = 'xiangsu_test' + SUBSCRIBE_TOPIC = 'xiangsu' KAFKA_CONSUMER_CONF = { 'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],