Kafka系列（六）、Kafka开发套件kafka lenses 安装及使用（带WebUI）

偏执的太偏执、 2022-12-10 02:23 158阅读 0赞

**目录**

介绍

安装

使用

--------------------

**Kafka系列：**

[kafka 2.4.1单机版部署及使用][kafka 2.4.1]

[kafka监控系统kafka eagle安装使用][kafka_kafka eagle]

[滴滴开源的kafka-manager编译及部署使用][kafka-manager]

[kafka管理监控系统 CMAK(yahoo的kafka-manager)部署及使用][kafka_ CMAK_yahoo_kafka-manager]

[Kafka系列（一）、2.6.0版本kafka集群搭建][Kafka_2.6.0_kafka]

[Kafka系列（二）、架构原理及存储机制][Kafka]

[Kafka系列（三）、生产者分区策略、ISR、ACK机制、一致性语义][Kafka_ISR_ACK]

[Kafka系列（四）、消费者策略、Rebalance机制、Offset存储机制][Kafka_Rebalance_Offset]

[Kafka系列（五）、开启SASL安全认证以及配置ACL权限控制][Kafka_SASL_ACL]

--------------------

# 介绍 #

Lenses 是kafka的一个商用套件，本次我们使用docker安装他们给我们提供的开源版本，该开源版本包含超多组件，对于平时开发使用来说很友好，不需要去安装一堆开发组件，它自带了Apache Kafka, Kafka Connect, Zookeeper, Confluent Schema Registry,Confluent  REST Proxy 以及几个lenses开源的管理ui界面 [kafka-topics-ui][], [schema-registry-ui][], [kafka-connect-ui][]， 还包含了30多种kafka connector，大大减少了我们安装部署的工作量，目前最新的镜像已经跟到kafka\_v2.5.1，还是挺新的。

**官方网址**：[https://lenses.io][https_lenses.io]

**Github**：[https://github.com/lensesio/fast-data-dev][https_github.com_lensesio_fast-data-dev]

# 安装 #

**Docker**

在安装lenses的开发镜像之前我们需要先准备docker环境，安装还是很简单的：

# 1. CentOS7 一键安装docker
    curl -fsSL https://get.docker.com | bash -s docker --mirror Aliyun
    
    # 2. 配置docker镜像加速，这里我使用的是阿里云的加速镜像，记得将下面的yourID换成自己的
    # 其他加速镜像：
    # https://docker.mirrors.ustc.edu.cn/
    # https://hub-mirror.c.163.com
    # https://registry.docker-cn.com
    vim /etc/docker/daemon.json
    #------------------
    {
      "registry-mirrors": ["https://yourID.mirror.aliyuncs.com"]
    }
    #------------------
    
    # 3. 执行命令重启服务
    sudo systemctl daemon-reload
    sudo systemctl restart docker
    
    # 4. 查看docker信息
    docker info

**kafka lenses：fast data dev**

使用下面的命令拉取并运行 lenses 开发镜像：

# 拉取镜像
    docker pull lensesio/fast-data-dev
    
    # 启动镜像
    docker run --rm -it     -p 2181:2181 -p 3030:3030 -p 8081:8081     -p 8082:8082 -p 8083:8083 -p 9092:9092 e ADV_HOST=127.0.0.1 lensesio/fast-data-dev

启动完成后在浏览器中输入ip:3030 即可看到下图界面：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70][]

# 使用 #

我们使用如下命令进入该镜像的命令行模式：

docker run --rm -it --net=host lensesio/fast-data-dev bash

然后创建一个topic 并开启一个producer 和consumer ：

# 创建一个topic：csdn_wyk
    kafka-topics --zookeeper 127.0.0.1:2181 --create --topic csdn_wyk --partitions 3 --replication-factor 1
    
    #开启一个生产者
    kafka-console-producer --broker-list 127.0.0.1:9092 --topic csdn_wyk
    
    # 开启一个消费者
    kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic csdn_wyk

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 1][]

回到刚才的lenses fast data 页面，在首页点击kafka-topics-ui即可进入如下页面，可以直接查看topic内的数据分区和配置项等信息：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 2][]

在首页点击 kafka-connect-ui即可进入下面的页面，在这里我们可以直接配置kafka connector：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 3][]

在首页点击 schema-registry-ui即可进入下面的页面，在这里我们可以管理注册到kafka schema registry的schema：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 4][]

希望本文对你有帮助，请点个赞鼓励一下作者吧~ 谢谢！

[kafka 2.4.1]: https://blog.csdn.net/wsdc0521/article/details/105813493
[kafka_kafka eagle]: https://blog.csdn.net/wsdc0521/article/details/105812299
[kafka-manager]: https://blog.csdn.net/wsdc0521/article/details/105833978
[kafka_ CMAK_yahoo_kafka-manager]: https://blog.csdn.net/wsdc0521/article/details/105846074
[Kafka_2.6.0_kafka]: https://blog.csdn.net/wsdc0521/article/details/108597755
[Kafka]: https://blog.csdn.net/wsdc0521/article/details/108604356
[Kafka_ISR_ACK]: https://blog.csdn.net/wsdc0521/article/details/108604420
[Kafka_Rebalance_Offset]: https://blog.csdn.net/wsdc0521/article/details/108604443
[Kafka_SASL_ACL]: https://blog.csdn.net/wsdc0521/article/details/108618997
[kafka-topics-ui]: https://github.com/lensesio/kafka-topics-ui
[schema-registry-ui]: https://github.com/lensesio/schema-registry-ui
[kafka-connect-ui]: https://github.com/lensesio/kafka-connect-ui
[https_lenses.io]: https://lenses.io
[https_github.com_lensesio_fast-data-dev]: https://github.com/lensesio/fast-data-dev
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70]: /images/20221123/c362809b682e40f4ac49efc8a1989d95.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 1]: /images/20221123/2413fa22c6094be6a7b2fda8a6f70897.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 2]: /images/20221123/975e265cb4b146f89c334e92fa9c844b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 3]: /images/20221123/1b00b5b8993a4b33b33c8b699e9c20e8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dzZGMwNTIx_size_16_color_FFFFFF_t_70 4]: /images/20221123/3af9aa245ef44b0b9c2948e4d767201a.png