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. 单击确定。
    您可以单击任务列表，查看执行结果。
    • 当状态为成功时，表示操作成功。
    • 当状态为失败时，您可以单击操作列的查看详情，排查失败的原因。