shanhai

settings.py

@@ -7,7 +7,7 @@ class Config:
                  'send_receive_timeout': 30}
 
     # 每个游戏不一样 游戏上报 kafka 主题
-    SUBSCRIBE_TOPIC = 'test2'
+    SUBSCRIBE_TOPIC = 'shanhai'
 
     KAFKA_CONSUMER_CONF = {
         'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],
@@ -15,7 +15,7 @@ class Config:
         'auto_offset_reset': 'earliest',
 
         # 每个游戏不一样
-        'group_id': 'legu_group3'
+        'group_id': 'shanhai_group'
     }
     # 游戏数据库名
     GAME = 'shjy'

user_view.sql

@@ -1,4 +1,4 @@
-create view shjy.user_view as select *
+create view shanhai.user_view as select *
                  from shjy.user
                  order by `#reg_time` desc
                  LIMIT 1 by `#account_id`

初始化事件表.sql

@@ -1,4 +1,4 @@
-create table shjy.event
+create table shanhai.event
 (
     `#ip`                     Nullable(IPv4),
     `#country`                Nullable(String),

初始化用户表.sql

@@ -1,4 +1,4 @@
-create table shjy.user
+create table shanhai.user
 (
 
     `#reg_time` DateTime('UTC'),