yr.datasystem.stream_client.Consumer.close# stream_client.Consumer.close()# 关闭消费者。一旦关闭后,消费者不可再用。 异常: RuntimeError - 关闭消费者失败。