当前位置:首页 > 服务端 > centos7 kafka安装并安装web界面监控工具

centos7 kafka安装并安装web界面监控工具

2022年08月05日 10:00:49服务端6

kafka自带zookeeper,所以不需要下载zookeeper

1、下载

wget http://mirrors.shu.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz

2、安装

tar -zxvf kafka_2.12-2.0.0.tgz

[root@log-system opt]# tar -zxvf kafka_2.12-2.0.0.tgz
[root@log-system opt]# cd kafka_2.12-2.0.0/
[root@log-system kafka_2.12-2.0.0]# ll
total 56
drwxr-xr-x. 3 root root  4096 Jul 24 22:20 bin
drwxr-xr-x. 2 root root  4096 Oct  8 17:01 config
drwxr-xr-x. 2 root root  4096 Oct  8 16:51 libs
-rw-r--r--. 1 root root 28824 Jul 24 22:17 LICENSE
drwxr-xr-x. 2 root root  4096 Oct  9 16:03 logs
-rw-r--r--. 1 root root   336 Jul 24 22:17 NOTICE
drwxr-xr-x. 2 root root    43 Jul 24 22:20 site-docs

3、配置

修改server.properties

vim config/server.properties

zookeeper.connect=localhost:2181

 

4、启动

[root@log-system kafka_2.12-2.0.0]# cd bin
[root@log-system bin]# ll
total 132
-rwxr-xr-x. 1 root root 1421 Jul 24 22:17 connect-distributed.sh
-rwxr-xr-x. 1 root root 1418 Jul 24 22:17 connect-standalone.sh
-rwxr-xr-x. 1 root root  861 Jul 24 22:17 kafka-acls.sh
-rwxr-xr-x. 1 root root  873 Jul 24 22:17 kafka-broker-api-versions.sh
-rwxr-xr-x. 1 root root  864 Jul 24 22:17 kafka-configs.sh
-rwxr-xr-x. 1 root root  945 Jul 24 22:17 kafka-console-consumer.sh
-rwxr-xr-x. 1 root root  944 Jul 24 22:17 kafka-console-producer.sh
-rwxr-xr-x. 1 root root  871 Jul 24 22:17 kafka-consumer-groups.sh
-rwxr-xr-x. 1 root root  948 Jul 24 22:17 kafka-consumer-perf-test.sh
-rwxr-xr-x. 1 root root  871 Jul 24 22:17 kafka-delegation-tokens.sh
-rwxr-xr-x. 1 root root  869 Jul 24 22:17 kafka-delete-records.sh
-rwxr-xr-x. 1 root root  866 Jul 24 22:17 kafka-dump-log.sh
-rwxr-xr-x. 1 root root  863 Jul 24 22:17 kafka-log-dirs.sh
-rwxr-xr-x. 1 root root  862 Jul 24 22:17 kafka-mirror-maker.sh
-rwxr-xr-x. 1 root root  886 Jul 24 22:17 kafka-preferred-replica-election.sh
-rwxr-xr-x. 1 root root  959 Jul 24 22:17 kafka-producer-perf-test.sh
-rwxr-xr-x. 1 root root  874 Jul 24 22:17 kafka-reassign-partitions.sh
-rwxr-xr-x. 1 root root  874 Jul 24 22:17 kafka-replica-verification.sh
-rwxr-xr-x. 1 root root 9290 Jul 24 22:17 kafka-run-class.sh
-rwxr-xr-x. 1 root root 1376 Jul 24 22:17 kafka-server-start.sh
-rwxr-xr-x. 1 root root  997 Jul 24 22:17 kafka-server-stop.sh
-rwxr-xr-x. 1 root root  945 Jul 24 22:17 kafka-streams-application-reset.sh
-rwxr-xr-x. 1 root root  863 Jul 24 22:17 kafka-topics.sh
-rwxr-xr-x. 1 root root  958 Jul 24 22:17 kafka-verifiable-consumer.sh
-rwxr-xr-x. 1 root root  958 Jul 24 22:17 kafka-verifiable-producer.sh
-rwxr-xr-x. 1 root root 1722 Jul 24 22:17 trogdor.sh
drwxr-xr-x. 2 root root 4096 Jul 24 22:17 windows
-rwxr-xr-x. 1 root root  867 Jul 24 22:17 zookeeper-security-migration.sh
-rwxr-xr-x. 1 root root 1393 Jul 24 22:17 zookeeper-server-start.sh
-rwxr-xr-x. 1 root root 1001 Jul 24 22:17 zookeeper-server-stop.sh
-rwxr-xr-x. 1 root root  968 Jul 24 22:17 zookeeper-shell.sh

先启动zk

[root@log-system bin]# ./zookeeper-server-start.sh -daemon ../config/zookeeper.properties

再启动kafka

[root@log-system bin]# ./kafka-server-start.sh -daemon ../config/server.properties

查看启动情况

[root@log-system bin]# netstat -tunlp|egrep "(2181|9092)"
tcp6       0      0 :::9092                 :::*                    LISTEN      15122/java          
tcp6       0      0 :::2181                 :::*                    LISTEN      14705/java

其中9092 是kafka端口,2181是zookeeper端口

 

kafka默认是没有web界面的,给kafka新增web界面

可以参照博客:https://blog.csdn.net/lsshlsw/article/details/47342821

centos7 kafka安装并安装web界面监控工具 _ JavaClub全栈架构师技术笔记

 

kafka使用

1、创建一个消息订阅队列

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic-pear

zookeeper:zookeeper host 和ip

replication-factor:副本数

partitions :分区数

topic :消息订阅名称

 

2、发布消息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic-pear

在界面输入

[root@log-system kafka_2.12-2.0.0]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic-pear
>您好
>大家好
>

 

3、消费消息

[root@log-system bin]# ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-pear --from-beginning
您好
大家好

通过监控界面可以看到创建的队列信息

centos7 kafka安装并安装web界面监控工具 _ JavaClub全栈架构师技术笔记

 

 


 

作者:A心有千千结
来源链接:https://blog.csdn.net/liurui_wuhan/article/details/82984615

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/server/17628.html

分享给朋友:

“centos7 kafka安装并安装web界面监控工具” 的相关文章

Kafka 安装和测试

Kafka 安装和测试

1. 简介 kafka (官网地址: http://kafka.apache.org)是一款分布式消息发布和订阅的系统,具有高性能和高吞吐率。 i. 消息的发布(publish)称作produ...

kafka启动后没反应

kafka使用脚本启动后后台没有进程 然后删除data和log目录下的所有文件 开启kafka,成功解决 作者:nidiquge 来源链接:https://blog.csdn.net/nidiquge/article/detail...

Windows环境中Kafka的安装及使用

Windows环境中Kafka的安装及使用

Kafka安装及使用 1. 简介 2.环境搭建 2.1安装JDK(例如JDK1.8等) 2.2 安装Zookeeper 2.3 安装Kafka...

Kafka安装

Lison <cundream@163.com>, v1.0.3, 2019.03.27 摘要 解决和排查kafka安装过程中,由于kafka安装版本所使用zookeeper版本与本地zookeeper安装版本不兼容,导致kafk...

spring-kafka 实战

spring-kafka 实战

spring-kafka实战 1.       kafka介绍   1.1.       主要功能 根据官网的介绍,Apach...

kafka安装步骤

kafka安装步骤

一、kafka介绍 1,kafka简单介绍 kafka是一款分布式、支持分区的、多副本,基于zookeeper协调的分布式消息系统。最大的特性就是可以实时处理大量数据来满足需求。 2,kafka使用场景 1,日志收集:可以用kafka收集各种服务的日志 ,...

CentOS7 安装kafka教程及启动

CentOS7 安装kafka教程及启动

介绍 Kafka是分布式发布-订阅消息系统,最初由LinkedIn公司开发,之后成为之后成为Apache基金会的一部分,由Scala和Java编写。Kafka是一种快速、可扩展的、设计内在就是分布式的,分区的和可复制的提交日志服务。 它与传统系统相比,有以下不同:...

Kafka安装之二 在CentOS 7上安装Kafka

Kafka安装之一  Zookeeper Kafka安装之二 在CentOS 7上安装Kafka 一、简介         Kafka是由Apache软件基金会开发的一个开...

windows安装kafka

windows安装kafka

一、下载kafka http://kafka.apache.org/downloads 选择二进制版本。 二、安装kafka 下载到本地后,将文件解压到本地磁盘下,该文件夹包括了所有相关的运行文件及配置文件,其子文件夹bin\w...

kafka安装部署(windows)

kafka安装部署(windows)

文章目录 前言 kafka安装部署(windows) 01 zookeeper中间件 安装部署 01::01 启动zook...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。