在使用消息队列Kafka版进行消息收发之前,您需要先在消息队列Kafka版控制台上创建资源,否则将无法通过鉴权认证及使用相关的管控运维功能。这里的资源概念是指Topic和Consumer Group。
前提条件
您已根据网络环境购买并部署
消息队列Kafka版服务:
背景信息
在成功部署消息队列Kafka版服务后,您需要创建Topic和Consumer Group。
- Topic:消息队列Kafka版里对消息进行的一级归类,例如可以创建 “Topic_Trade” 这一主题用来识别交易类消息。使用消息队列Kafka版的第一步就是先为您的应用创建Topic。
- Consumer Group:一类Consumer,这类Consumer通常接收并消费同一类消息,且消费逻辑一致。Consumer Group和Topic的关系是N:N,即同一个Consumer
Group可以订阅多个Topic,同一个Topic也可以被多个Consumer Group订阅。
步骤一:创建Topic
请按照以下步骤创建Topic:
- 登录消息队列Kafka版控制台。
- 在顶部菜单栏,选择地域。
注意 Topic需要在应用程序所在的地域(即所部署的ECS的所在地域)进行创建。Topic不能跨地域使用。例如Topic创建在华北2(北京)这个地域,那么消息生产端和消费端也必须运行在华北2(北京)的ECS。
- 在左侧导航栏,单击实例列表。
- 在实例列表页面,单击目标实例名称。
- 在左侧导航栏,单击Topic管理,然后单击创建 Topic。
- 在创建Topic对话框,设置Topic属性,然后单击创建。
完成后,您创建的Topic将出现在Topic管理页面的列表中。
步骤二:创建Consumer Group
请按照以下步骤创建Consumer Group:
- 在消息队列Kafka版控制台的左侧导航栏,单击Consumer Group管理。
- 在Consumer Group管理页面,选择实例,单击创建Consumer Group。
- 在创建Consumer Group页面,填写Consumer Group的名称,并选择该Consumer Group所在的实例,选择标签,然后单击创建。
完成后,您创建的Consumer Group将出现在Consumer Group管理页面的列表中。
在文档使用中是否遇到以下问题
更多建议
匿名提交