Kafka元数据管理适用于EMR-3.17.0后续版本。新创建的Kafka集群会自动创建Kafka元数据。本文介绍Kafka元数据的基本操作。

进入Kafka数据管理页面

  1. 登录阿里云E-MapReduce控制台
  2. 在顶部菜单栏处,根据实际情况选择地域(Region)和资源组
  3. 单击上方的元数据管理页签。
  4. 在左侧导航栏,单击Kafka数据管理

添加Topic

  1. 进入Kafka数据管理页面
  2. Kafka数据管理页面,单击右上角的添加Topic
  3. 基本配置区域,配置各项参数。
  4. 可选:高级配置区域,可单击右上角添加,输入Key和Value增加配置项。
  5. 单击确定
    您可以单击任务列表,查看执行结果。
    • 状态成功时,表示操作成功。
    • 状态失败时,您可以单击操作列的查看详情,排查失败的原因。

删除Topic

注意
  • 内置的Topic(__consumer_offsets_schemas)不支持删除。
  • 已经释放的集群不支持删除。
  1. 进入Kafka数据管理页面
  2. Kafka数据管理页面,单击对应Topic所在行的删除
  3. 单击确定
    您可以单击任务列表,查看执行结果。
    • 状态成功时,表示操作成功。
    • 状态失败时,您可以单击操作列的查看详情,排查失败的原因。

更新配置

注意
  • 内置的Topic(__consumer_offsets_schemas)不支持更新。
  • 已经释放的集群不支持更新。
  1. 进入Kafka数据管理页面
  2. Kafka数据管理页面,单击对应Topic所在行的更新配置
  3. 修改相应的配置信息。
  4. 单击确定
    您可以单击任务列表,查看执行结果。
    • 状态成功时,表示操作成功。
    • 状态失败时,您可以单击操作列的查看详情,排查失败的原因。

查看Topic详情

  1. 进入Kafka数据管理页面
  2. Kafka数据管理页面,单击对应Topic所在行的详情
    您可以查看该Topic的监控数据、摘要信息、数据分布和消费组。

批量调整分区

  1. 进入Kafka数据管理页面
  2. Kafka数据管理页面,单击批量调整分区
  3. 批量调整分区对话框中,单击选择Topic
  4. 选择Topic对话框中,从集群 ID列表选择待调整分区所属的集群。
  5. 选中待调整的分区,单击确定
  6. 设置调整后的分区数。
  7. 单击确定
    您可以单击任务列表,查看执行结果。
    • 状态成功时,表示操作成功。
    • 状态失败时,您可以单击操作列的查看详情,排查失败的原因。