Kafka Manager是專為Kafka設計的集群管理工具,提供了WebUI界面,允許用戶通過圖形化界面便捷地管理Kafka集群。本文為您介紹如何訪問Kafka Manager的WebUI,并將集群添加至Kafka Manager的WebUI界面。
前提條件
已創建選擇了Kafka服務的DataFlow集群,創建詳情請參見創建集群。
當選擇了Kafka服務,系統將默認安裝Kafka Manager軟件服務,并開啟Kafka Manager的認證功能。
注意事項
使用Kafka Manager進行partition reassign功能時,當前版本的Kafka Manager是沒有提供限流功能的。如果需要限流,您可以通過kafka-configs.sh手工配置限流參數,具體限流方式請參見限制Kafka服務端運維流量。
操作步驟
使用SSH隧道方式訪問Web頁面,詳情請參見通過SSH隧道方式訪問開源組件Web UI。
說明建議您首次使用Kafka Manager時修改默認密碼。
為了防止8085端口暴露,建議使用SSH隧道方式來訪問Web界面。如果使用http://localhost:8085方式訪問Web界面,請做好IP白名單保護,避免數據泄露。
在登錄頁面,輸入用戶名和密碼。
用戶名、密碼和Zookeeper地址,您可以通過以下步驟獲取:
在頂部菜單欄處,根據實際情況選擇地域和資源組。
在EMR on ECS頁面,單擊目標集群操作列的集群服務。
獲取以下配置信息。
獲取用戶名和密碼:
在集群服務頁面,單擊Kafka Manager服務區域的配置。
在配置頁面,查看以下參數的值:
kafka.manager.authentication.username:登錄Kafka Manager頁面的用戶名。
kafka.manager.authentication.password:登錄Kafka Manager頁面的密碼。
獲取集群的Zookeeper地址:
在集群服務頁面,單擊Kafka服務區域的配置。
在配置頁面,查看server.properties頁簽下的zookeeper.connect的參數值,即集群的Zookeeper地址。
在Kafka Manager頁面,選擇
。在Add Cluster頁面,配置以下參數,單擊Save。
參數
描述
Cluster Name
集群名稱。
Cluster Zookeeper Hosts
集群的Zookeeper地址。
填寫在步驟2中獲取到的zookeeper.connect的值。
Kafka Version
選擇對應的Kafka版本。
說明由于Kafka Manager可能不支持高版本的Kafka,所以此參數值選擇最接近的版本即可。
Enable JMX Polling (Set JMX_PORT env variable before starting kafka server)
是否開啟JMX功能。
本示例開啟了JMX功能。
brokerViewThreadPoolSize
獲取數據時的線程池大小。
重要修改參數值大于2。
創建好之后即可使用常見的Kafka功能。