全部产品

步骤三:创建资源

更新时间:2019-04-25 18:52:10

在使用消息队列 Kafka 进行消息收发之前,您需要先在消息队列 Kafka 控制台上创建资源,否则将无法通过鉴权认证及使用相关的管控运维功能。这里的资源概念是指 Topic 和 Consumer Group。

步骤一:创建 Topic

消息主题(Topic)是消息队列 Kafka 里对消息进行的一级归类,比如可以创建“Topic_Trade”这一主题用来识别交易类消息。使用消息队列 Kafka 的第一步就是先为您的应用创建 Topic。

请按照以下步骤创建 Topic:

  1. 登录消息队列 Kafka 控制台

  2. 在左侧导航栏,单击 Topic管理

  3. Topic管理页面,单击创建Topic 按钮。

  4. 创建Topic 页面,输入 Topic 名称,选择 Topic 所在的实例,再输入备注和分区数,然后单击创建

完成后,您创建的 Topic 将出现在 Topic管理页面的列表中。

注意:

  • Topic 也需要在应用程序所在的地域(即所部署的 ECS 的所在地域)进行创建。

  • Topic 不能跨地域使用。比如 Topic 创建在华北2(北京)这个地域,那么消息生产端和消费端也必须运行在华北2(北京)的 ECS 上。

  • 有关地域的详细介绍请参见 ECS 文档中的地域和可用区

步骤二:创建 Consumer Group

创建完 Topic 后,请按以下步骤创建 Consumer Group:

  1. 在消息队列 Kafka 控制台的左侧导航栏,单击 Consumer Group管理

  2. Consumer Group 管理页面,单击 创建Consumer Group 按钮。

  3. 创建Consumer Group 页面,填写 Consumer Group 的名称,并选择该 Consumer Group 所在的实例,然后单击创建

完成后,您创建的 Consumer Group 将出现在 Consumer Group管理页面的列表中。

注意:Consumer Group 和 Topic 的关系是 N:N。 同一个 Consumer Group 可以订阅多个 Topic,同一个 Topic 也可以被多个 Consumer Group 订阅。