我使用aiokafka==0.5.2作为kafka的python库
我有示例中的代码：

async def consume():
    consumer = AIOKafkaConsumer(
        'my_topic', 'my_other_topic',
        loop=loop, bootstrap_servers='localhost:9092',
        group_id="my-group")

    await consumer.start()
    try:
        # Consume messages
        async for msg in consumer:
            #...

当我运行它-它工作良好。但当我停止Kafka服务器-我的应用程序继续挂起等待消息。我猜，当prod server将kafka节点排除在平衡之外时，我的应用程序对此一无所知。我怎么能有Kafka在我的应用程序连接监听？