kafka-ui 部署与使用

1.前提准备

  • 部署节点应安装 Docker。

2.部署

上传镜像包到节点，使用docker导入镜像，此镜像为官方0.4.0版本镜像。

docker load < kafka-ui.tar

使用docker-compose来部署kafka-ui服务。在合适的位置生成并编辑docker-compose.yml文件。

vim docker-compose.yml

docker-compose.yml:

version: '2'
services:
  kafka-ui:
    image: provectuslabs/kafka-ui:0.4.0
    container_name: kafka-ui
    ports:
      - "8082:8080"  # 设置默认端口，官方默认为8080，这里设置8082来避开被占用的端口
    restart: always
    environment:
      KAFKA_CLUSTERS_0_NAME: group1 # 组名，这个组是kafka-ui内的逻辑单位，表示一个kafka集群
      KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: {{hostname}}:9092
      AUTH_TYPE: "LOGIN_FORM"
      SPRING_SECURITY_USER_NAME: admin # 设置登录用户名
      SPRING_SECURITY_USER_PASSWORD: kafkaui # 设置登录密码

cluster即为kafka-ui提供的逻辑分组功能。要在kafka-ui中分组查看kafka节点，在上述配置文件的environment配置形如KAFKA_CLUSTERS_1_NAME，KAFKA_CLUSTERS_2_NAME即可，kafka-ui会提供以cluster划分的统计信息。

使用docker-compose启动。

docker-compose up -d

3.访问与使用

浏览器访问 http://hostname:8082 即可访问页面，登录后可以查看相应的broker、topic、消费者组信息。

在topics中点进"topic-message"可以查看消息，右上角“produce message”可以生产消息到topic中。