在登记数据源后,如果想要消费kafka消息队列中的消息,我们需要将kafka登记为流表。由于本平台是通过 [数据源.]数据库.表 三元组的方式识别并定位到具体的表,而流表本身并不存在于某个数据库中,因此我们需要为流表创建一个虚拟的数据库,用于管理并使用流表。

每一个项目默认存在一个 catalog(可以理解成一类数据源,这里指流表这种数据源),库挂载在 catalog 下。创建库需要走工单审批流程,审批对象为管理员和负责人。

新建数据库流程


  1. 登录Eaystreaam→点击数仓→流表管理→新建数据库。

    新建数据库1

  2. 填入信息并确定,等待管理员审批。

    新建数据库2

  3. 管理员审核通过后数据库新建成功。