E-MapReduce支持通过Kafka Manager服务对Kafka集群进行管理。

前提条件

注意 创建Kafka集群时默认安装Kafka Manager软件服务,并开启Kafka Manager的认证功能。

已创建Kafka类型的集群。

操作步骤

  1. 使用SSH隧道方式访问Web页面,详情请参见通过SSH隧道方式访问开源组件Web UI
    说明
    • 建议您首次使用Kafka Manager时修改默认密码。
    • 为了防止8085端口暴露,建议使用SSH隧道方式来访问Web界面;如果使用http://localhost:8085方式访问Web界面,请做好IP白名单保护,避免数据泄漏。
  2. 在登录页面,输入用户名密码

    详细信息可通过以下步骤获取。

    1. 通过主账号登录阿里云 E-MapReduce 控制台
    2. 在顶部菜单栏处,选择地域(Region)。根据实际情况选择资源组,默认显示账号全部资源。
    3. 单击上方的集群管理页签。
    4. 集群管理页面的集群列表中,单击对应集群后面的详情
    5. 在左侧导航栏,选择集群服务 > Kafka-Manager
    6. 单击配置,在服务配置区域,用户名请查看kafka.manager.authentication.username、密码请查看kafka.manager.authentication.passwordkafka configure
    7. Kafka集群的Zookeeper地址,请查看kafka.manager.zookeeper.hosts
  3. 添加一个创建好的Kafka集群。
    1. 输入集群名称。
    2. 配置Kafka集群的Zookeeper地址。

      填写在步骤2中获取kafka.manager.zookeeper.hosts的值。

    3. 选择对应的Kafka版本。
    4. 建议打开JMX功能。添加Kafka集群
    创建好之后即可使用一些常见的Kafka功能。常见Kafka功能。