更新时间:2022-12-13 GMT+08:00

管理Kafka集群

管理Kafka集群包含以下内容:

添加集群到KafkaManager的WebUI界面

首次创建Kafka集群后会在KafkaManager的WebUI界面创建名为my-cluster的默认Kafka集群,用户也可以在KafkaManager的WebUI界面自行添加已经通过MRS控制台创建的Kafka集群,用于管理多个Kafka集群。

  1. 登录KafkaManager的WebUI界面。
  2. 在页面上方选择Cluster > Add Cluster

    图1 添加集群

  3. 设置待添加集群的参数,如下参数请参考样例,其他参数默认不需要修改。

    表1 需修改的集群参数

    参数名称

    取值样例

    说明

    Cluster Name

    mrs-demo

    待添加集群在KafkaManager的WebUI界面中显示的名称。

    Cluster Zookeeper Hosts

    zk1_ip:zk1_port, zk2_ip:zk2_port/kafka

    待添加集群的Zookeeper地址。

    Kafka Version

    1.1.0

    待添加集群的Kafka版本,默认1.1.0。

    Enable JMX Polling (Set JMX_PORT env variable before starting kafka server)

    勾选

    -

    Poll consumer information (Not recommended for large # of consumers)

    勾选

    -

    Enable Active OffsetCache (Not recommended for large # of consumers)

    勾选

    -

    Display Broker and Topic Size (only works after applying this patch)

    勾选

    -

    Security Protocol

    PLAINTEXT

    • 开启Kerberos的Kafka集群选择SASL_PLAINTEXT
    • 未开启Kerberos集群选择PLAINTEXT

  4. 单击“Save”完成添加集群。

更新集群参数

  1. 登录KafkaManager的WebUI界面。
  2. 在对应集群的“Operations”列单击“Modify”

    图2 更新集群参数

  3. 进入集群配置参数页面,修改集群参数。

删除KafkaManager的WebUI界面的集群

  1. 登录KafkaManager的WebUI界面。
  2. 在对应集群的“Operations”列单击“Disable”

    图3 停用集群

  3. 等待集群列表页面的“Operations”列出现“Delete”“Enable”时,单击“Delete”删除集群。也可以单击“Enable”启用集群。

    图4 启用或删除集群