介绍

安装

使用

Kafka系列：

kafka 2.4.1单机版部署及使用

kafka监控系统kafka eagle安装使用

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

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

Kafka系列（一）、2.6.0版本kafka集群搭建

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

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

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

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

Github：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 即可看到下图界面：

使用

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

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

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

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

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

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

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

Kafka系列（七）、Kafka套件 Confluent Platform 单机/集群部署
目录简介单机部署集群部署尾巴 Kafka系列: kafka 2.4.1单机版部署及使用 kafka监控系统kafka eagle安装使用滴滴开源的kafka-manager编译及部署使用 k ...
Kafka系列之：深入理解Kafka 主题、分区、副本、LEO、ISR、HW、Kafka的主写主读和分区leader选举
Kafka系列之:深入理解Kafka 主题.分区.副本.LEO.ISR.HW.Kafka的主写主读和分区leader选举一.Kafka重要知识点提炼二.详细介绍Kafka 主题.分区.副本.LEO ...
Kafka系列之：不重启kafka集群设置kafka topic数据保留时间
Kafka系列之:不重启kafka集群设置kafka topic数据保留时间一.kafka topic数据保留3天的bash命令二.查看kafka删除数据日志三.批量设置上千个topic保留3天 ...
信息学奥赛系列教程：开发工具Dev C++安装
Dev C++安装和基本设置工欲善其事,必先利其器,学习C++语言编程,需要使用相关的开发工具,C++语言的程序的开发工具有很多,比如微软的VS,之所以选择Dev c++,是因为: Dev C++是 ...
kafka创建topic_ELK-基础系列(六)-ELK加入消息队列-Kafka部署
Kafka集群部署指南一.前言 1.Kafka简介 Kafka是一个开源的分布式消息引擎/消息中间件,同时Kafka也是一个流处理平台.Kakfa支持以发布/订阅的方式在应用间传递消息,同时并基于消 ...
2021年大数据Kafka（六）：❤️安装Kafka-Eagle❤️
全网最详细的大数据Kafka文章系列,强烈建议收藏加关注! 新文章都已经列出历史文章目录,帮助大家回顾前面的知识重点. 目录系列历史文章安装Kafka-Eagle 一.Kafka-eagle基本介 ...
Cris 玩转大数据系列之消息队列神器 Kafka
Cris 玩转大数据系列之消息队列神器 Kafka Author:Cris 文章目录 Cris 玩转大数据系列之消息队列神器 Kafka Author:Cris 1. Kafka 概述 1.1 消息队 ...
Kafka基础系列第1讲：Kafka的诞生背景及应用
Kafka 是由 LinkedIn 开发的一个分布式的消息系统,使用 Scala 编写,它以可水平扩展和高吞吐率而被广泛使用.目前越来越多的开源分布式处理系统如 Cloudera.Apache Sto ...
Kafka系列之-Kafka Protocol实例分析
本文基于A Guide To The Kafka Protocol文档,以及Spark Streaming中实现的org.apache.spark.streaming.kafka.KafkaClust ...

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

介绍

安装

使用

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

最新文章

热门文章