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

前提条件

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

已创建集群类型为Kafka的集群。

操作步骤

  1. 使用SSH隧道方式访问Web界面，请参见 SSH 登录集群。

    说明
    • 建议您首次使用Kafka Manager时修改默认密码。
    • 为了防止8085端口暴露，建议使用SSH隧道方式来访问Web界面；如果使用http://localhost:8085方式访问Web界面，请做好IP白名单保护，避免数据泄漏。

  2. 在登录界面，输入用户名和密码。

    详细信息可单击集群管理，在集群服务 > Kafka-Manager页面的服务配置区域，查看用户名和密码。

    kafka configure

  3. 添加一个创建好的Kafka集群。

    1. 输入集群名称。

    2. 配置正确Kafka集群的Zookeeper地址。

      详细信息可单击集群管理，在集群服务 > Kafka-Manager页面的服务配置区域，查看kafka.manager.zookeeper.hosts。

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