管理Kafka集群
管理Kafka集群包含以下内容:
添加集群到KafkaManager的WebUI界面
首次创建Kafka集群后会在KafkaManager的WebUI界面创建名为my-cluster的默认Kafka集群,用户也可以在KafkaManager的WebUI界面自行添加已经通过MRS控制台创建的Kafka集群,用于管理多个Kafka集群。
- 登录KafkaManager的WebUI界面。
- 在页面上方选择
。图1 添加集群
- 设置待添加集群的参数,如下参数请参考样例,其他参数默认不需要修改。
表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
- 单击“Save”完成添加集群。