doseeing

import jwt
import time
import asyncio
import websockets
from websockets.extensions import permessage_deflate

from config import huya_app_id, huya_app_secret

async def keep_alive(ws):
    while True:

doseeing

from aiokafka import AIOKafkaConsumer
import asyncio
import tracemalloc

tracemalloc.start()

kafka_host, kafka_port, kafka_consumer_group = '127.0.0.1', 9092, 'mygroup-id'


async def consume(topic, group_id):