Kafka单机版安装教程及测试(附每一步操作截图及说明)【一看就懂】
衔接上文,若对kafka还不太了解的朋友请参考:
一文带你了解Kafka【一看就懂】_杨大仙-CSDN博客
| 1.校验java环境及JDK是否已安装
java -version
若还没有安装,请先安装配置java环境:
Linux系统中Java环境的搭建及JDK的安装(附上每一步操作截图及说明)【一看就懂】_杨大仙-CSDN博客
| 2.上传kafka文件至虚拟机中
官网下载链接:Apache Kafka
本文使用该版本为例(kafka_2.11-1.0.0.tgz)
准备好压缩包后将其上传至虚拟机:如图所示:
解压刚上传的kafka压缩文件:
tar -zxvf kafka_2.11-1.0.0.tgz
| 3.切换到kafka的配置文件目录
kafka安装目录下的config文件夹为其存放配置文件的位置
从根目录进入命令:(快捷生成文件名方式,敲一个文件首字母后按Tab键即可自动生成)
cd /opt/kafka_2.11-1.0.0/config/
| 4.修改server.properties和zookeeper.properties配置文件
使用vim编辑器打开server.properties配置文件界面如下所示,并使用命令调出行号
若对vim编辑器不太了解的请参考:
Linux系统中 vi/vim编辑器 的介绍及使用大全 详解【一看就懂】_杨大仙-CSDN博客_vim键盘
vim server.properties
:set nu --->显示行号
将第31行左右listeners复制并添加本机ip;
修改日志路径,分区数,可根据需求修改。
修改完成后保存退出配置文件。并创建对应配置文件中日志存放位置的文件夹:
再使用vim编辑器进入zookeeper.properties
文件内容非常的少,我们只需参考图示进行操作即可:
需要开放防火墙中 2181 端口和 9092 端口。
对防火墙规则不太了解的朋友请参考:(本文就不做开放防火墙演示了,避免文章过于冗余)
【黑客必备】Linux系统中防火墙Firewall操作详解(附上图示及说明)【一看就懂】_杨大仙-CSDN博客
操作完成后保存并退出该配置文件。
| 5.启动
到此呢Kafka单机版安装就已经成功,接下来我们启动测试一下。
启动zookeeper
/opt/kafka_2.11-1.0.0/bin/zookeeper-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/zookeeper.properties
- 启动 kafka 之前需要启动 zookeeper 因为 kafka 依赖于 zookeeper ;
- 启动 zookeeper 要去加载 zookeeper 的配置文件 和启动 redis 时,加载 redis.conf 文件一样;
再启动kafka-server
如图所示:(这里使用了绝对路径,若你的kafka文件目录与我一致,复制即可)
/opt/kafka_2.11-1.0.0/bin/kafka-server-start.sh -daemon /opt/kafka_2.11-1.0.0/config/server.properties
启动成功后使用jps查看进程,启动成功
jps
若错误操作先启动了kafka,会出现如下错误:
kafka创建主题时循环报错 java.net.ConnectException: 拒绝连接...【已解决】_杨大仙-CSDN博客
| 5.1查看所有主题
复制后记得修改ip地址为你的ip地址;
/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --list --zookeeper 192.168.21.132:2181
目前还没有主题。
| 5.2创建主题
/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --create --zookeeper 192.168.21.132:2181 -partitions 1 --replication-factor 1 --topic test
- replication-factor 1: 备份(副本) 最多为集群机器的台数 只能少不能多 单机版只能是1
- partitions 1: 分区数
| 5.3删除主题
删除主题命令如下:就不做展示啦,嘿嘿
/opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --delete --zookeeper 192.168.21.131:2181 --topic test
| 5.4启动生产者(发送消息)
命令如下:(这里使用了绝对路径,若你的kafka文件目录与我一致,复制即可)
/opt/kafka_2.11-1.0.0/bin/kafka-console-producer.sh --broker-list 192.168.21.131:9092 --topic test
启动成功后可发送消息(如上图);然后复制当前标签并打开,准备测试消费者;
| 5.5启动消费者(拉取消息)
命令如下:(这里使用了绝对路径,若你的kafka文件目录与我一致,复制即可)
/opt/kafka_2.11-1.0.0/bin/kafka-console-consumer.sh --bootstrap-server 192.168.21.131:9092 --topic test --from-beginning
参数:--from-beginning 加上即代表从第一条开始接收
ok,到此我们便大功告成啦,祝玩的开心~
Kafka启动之我直接开挂 lbwnb_杨大仙-CSDN博客
转载请注明出处
如有错误,欢迎指正
Thanks
Kafka单机版安装教程及测试(附每一步操作截图及说明)【一看就懂】相关推荐
- Oracle Primavera P6 R84单机版安装教程
本教程用于指导Oracle Primavera P6 R84版本的单机版安装过程.P6 R84版本于2014年9月30日发布.其功能较之前版本有较大提升.单机版的安装方式也发生了很大的变化.P6 R8 ...
- Docker Kafka 单机版安装
一.安装 下载library/zookeeper并运行 docker run --name zookeeper -d -p 2181:2181 -v /etc/localtime:/etc/local ...
- 魔域mysql_魔域单机版安装教程
最近收到很多人关于<魔域单机版>玩不了的问题,小编整理下这些问题,一般都是mysql没有运行,或者是游戏启动的时候,出现一个启动中,然后就没有然后了. 对于这些问题,我们牛游戏网也是很在意 ...
- Proteus 8.12 SP0安装教程(内附软件安装包有视频教程)
基本简介 Proteus 8.12是一款是功能强大的PCB设计套件,是现代EDA开发的PCB设计和电路模拟器软件.将易用性与强大的功能集结合在一起,可以快速设计,测试和布置专业印刷电路板.Proteu ...
- deepin efi 启动u盘_深度系统(Deepin Linux)U盘安装教程!!附学习资料,干货
首先在深度系统(Deepin Linux)的官网下载安装镜像.准备好一个U盘,系统镜像约2.2G,所以U盘的容量应该不小于这个空间,保持至少3G以上. 镜像下载完成后打卡镜像,在Windows8和Wi ...
- opencv安装教程python3.7_python3.7 -openCV安装教程与测试
安装过程 在windows10 系统中安装 Anaconda3 与opencv. 一.安装python 我安装的是Anaconda3下python是3.7版本,使用的是Anaconda3-5.3.0- ...
- 在虚拟机中安装Linux系统 (附上每一步操作截图及说明)【一看就懂】
我们在电脑上安装虚拟机后,一般会在虚拟机上安装Linux系统搭配使用,本文附上每一步操作流程截图及说明 虚拟机安装教程:VMware15虚拟机超详细安装教程(附上每一步操作流程截图及说明)[一看就懂] ...
- csdn入门测试教程------mysql数据库命令大全以及常用命令 安装教程 基础知识 附【练习题】
前言: mysql数据库是每一个测试小白入行必学的一个知识,学会这些命令呢也能让你在玩转数据库的时候给你提供很多的便利也是很不错的,最后希望各位小伙伴学有所成,心想事成咯, 废话不多说直接上正文. [ ...
- FastDFS单机版安装教程
安装清单如下: 一.安装FastDFS 1. 安装libfastcommon 先解压安装包到目录 # unzip libfastcommon-1.0.36.zip 安装编译工具及环境(后面Nginx也 ...
最新文章
- WEB+windows集群
- php定时发送生日模块消息_RocketMQ消息队列介绍与应用
- 浅析商业银行“业务连续性管理体系”的构建
- 【数字信号处理】希尔伯特变换系列1之相位处理(含MATLAB代码)
- mybatis insert 动态生成插入的列及插入的值
- python全栈计划_Python 全栈学习视频教程,包含了从 0-99天的全栈学习计划,估计可以学习 1024 小时。...
- 数据库中常见的面试问题(转)
- DB and RAC(11.2.0.3 ) Patch Set Update(11.2.0.3.6 )
- HTML:canvas画圆形加矩形组合
- 7月28日吃鸡端游服务器维护,绝地求生7月28日维护到什么时候结束
- 单位dB和dBm的区别
- win7 64位官方旗舰版上搭建ruby on rails的步骤
- Python 编程笔记(本人出品,必属精品)
- python爬虫出现ProxyError: HTTPSConnectionPool错误
- 1.1 windows环境安装Perl
- STM32——通用定时器控制超声波传感器HCSR04
- SegmentFault Hackathon 文艺复兴今在沪举行
- 【计量经济学】统计推断
- tomcat中catalina是什么
- Unity3D : 腾讯云语音(GCloudVoice)的语音转文字功能
热门文章
- 【贼好理解!!】C++ list链表常用成员函数讲解
- 颜色外观模型:人眼视觉理论基础
- 看上旷视又要投了?全面拆解阿里AI布局 | 人工智能观察
- 暴风雨中的幸福——记我敬爱的米老师
- 图解PMP项目管理马斯洛需求层次理论在公司管理中的应用!
- 智能wifi小车-RGB三色LED灯驱动
- 医院 社区 远程会诊系统 远程预约挂号系统 双向转诊系统 欣赏可做毕业设计
- ADAS推高毫米波雷达需求,上游企业如何跟进?
- 记录java.util.Collections.unmodifiableList()使用
- Linux——Linux驱动之GPIO中断的应用实战(上)(中断概述及相关函数、设备树中指定中断、驱动中获取中断)