linux安装kafka

不念不忘少年蓝@ 2022-01-14 12:09 248阅读 0赞

> 今天来安装kafka 安装kafka前台必须安装zookeeper 不会安装请移步：[点我快速进入安装zookeeper文章][zookeeper]

> 一、安装kafka

> 下载kafka两种方式

> 1、手动下载 下载地址：http://kafka.apache.org/downloads

![file][]

> 下载好了然后上传服务器（不在这里赘述。前两个文章都有！）

> 2、也可以用命令下载（直接下载到服务器哦！）：

![file][file 1]

命令：wget http://mirrors.hust.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz

> 二、解压kafka：

![file][file 2]

命令：tar -xzvf kafka_2.12-2.0.0.tgz（文件名可以更换哦！）

> 三、修改server.properties文件

![file][file 3]

在config目录下输入命令：vi server.properties

> 修改内容为：

![file][file 4]

server.properties修改 内容如下：可直接复制粘贴。
    broker.id=0 
    port=9092 #端口号 
    host.name=localhost #单机可直接用localhost
    log.dirs=/DATA/kafka/kafka_2.12-2.0.0/log #日志存放路径可修改可不修改
    zookeeper.connect=localhost:2181 #zookeeper地址和端口，单机配置部署，localhost:2181

> 由于我修改了日志存放地址 我需要创建一个文件夹

![file][file 5]

命令：直接在kafka目录下输入：mkdir log

> 四、修改zookeeper.properties文件

![file][file 6]

进入kafka目录下 config目录下输入命令：vi  zookeeper.properties
    
    修改内容为：
    dataDir=/DATA/kafka/kafka_2.12-2.0.0/zookeeper/data/dataDir  #zookeeper数据目录  (可以修改可以不修改)
    dataLogDir=/DATA/kafka/kafka_2.12-2.0.0/zookeeper/data/dataLogDir #zookeeper日志目录 （可以修改可以不修改）
    clientPort=2181 
    maxClientCnxns=100 
    tickTime=2000 
    initLimit=10

> 由于我修改了默认的数据目录地址和日志目录需要创建文件夹如下图：

![file][file 7]

> 五、修改完之后就可以启动zookeeper和kafka了。直接敲命令感觉有些low呀。弄一个脚本命令吧： 启动脚本：

![file][file 8]

进入kafka目录下 输入命令：vi  kafkaStart.sh
    
    添加内容为：
    #!/bin/bash
    #启动zookeeper
    /DATA/kafka/kafka_2.12-2.0.0/bin/zookeeper-server-start.sh /DATA/kafka/kafka_2.12-2.0.0/config/zookeeper.properties &
    sleep 3  #默默等3秒后执行 
    #启动kafka
    /DATA/kafka/kafka_2.12-2.0.0/bin/kafka-server-start.sh /DATA/kafka/kafka_2.12-2.0.0/config/server.properties &

> 添加脚本执行权限：

![file][file 9]

在刚创建的脚本目录许下执行以下命令
    chmod +x kafkastart.sh（启动脚本名称）

> 六、启动kafka

> 1、先启动zookeeper。

![file][file 10]

启动命令：sh $zookeeper_home/bin/zkServer.sh start

> 2、启动kafka

![file][file 11]

在kafka目录下输入 启动脚本命令： ./kafkaStart.sh

> 七、创建topic 出现Created topid test 则创建成功

![file][file 12]

命令：在kafka 目录下bin目录下执行：
    ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test  test是topic名字可以随便换哦。

> 查询创建的top主题 出现test则为正常

![file][file 13]

命令：在kafka 目录下bin目录下执行：
    ./kafka-topics.sh --list --zookeeper localhost:2181

> 删除创建的topic

![file][file 14]

命令：在kafka 目录下bin目录下执行：
    ./kafka-topics.sh --delete --zookeeper localhost:2181 --topic   要删除的topic名称

> 八、测试生成者（test topic）：

![file][file 15]

命令：在kafka 目录下bin目录下执行：
    ./kafka-console-producer.sh --broker-list localhost:9092 --topic test（要启动生成者的topic名称）

> 九、测试消费者 启动另一个xsheel窗口 这样效果更明显哦！（test topic）：

![file][file 16]

命令：在kafka 目录下bin目录下执行：
    ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

> 十、生产者发送消息：

![file][file 17]

> 十一、消费者消费消息：

![file][file 18]

> 发送完消息消费者会变成感叹号哦！点击查看输入内容已经打印控制台证明消费成功。

![file][file 19]

> 十二、到此结束kafka单机版本就集成了哦。我们来停止kafka网上有很多脚本 你们可以参考一下

> 关闭脚本：

![file][file 20]

进入kafka目录下 输入命令：vi  kafkaStop.sh
    #!/bin/bash
    #关闭zookeeper
    /DATA/kafka/kafka_2.12-2.0.0/bin/zookeeper-server-stop.sh  /DATA/kafka/kafka_2.12-2.0.0/config/zookeeper.properties &
    sleep 3 #默默等3秒后执行 
    #关闭kafka
    /DATA/kafka/kafka_2.12-2.0.0/bin/kafka-server-stop.sh /DATA/kafka/kafka_2.12-2.0.0/config/server.properties &

> 关闭命令：

> 关闭kafka：

在kafka目录下执行
    ./kafkaStop.sh

> 关闭zookeeper

sh $zookeeper_home/bin/zkServer.sh stop

> 但是他会报没有启动着zookeeper和kafka

![file][file 21]

> 我们ps-ef | grep kafka 一下你会发现还在启动着。

![file][file 22]

> 上面的方法我没成功。你们可以测试一下。用最粗暴的方法把。

![file][file 23]

ps -ef | grep kafka
    kill -9  kafka进程号
    ps -ef | grep zookeeper
    kill -9  zookeeper进程号

> 注意：一定要先关闭kafka在关闭zookeeper ！！！ 如果先关闭zookeeper kafka会一直去连接zookeeper服务 进入死循环了。 如果进入死循环有两种解决办法：

> 1、重启服务

shutdown -h 10          #计算机将于10分钟后关闭，且会显示在登录用户的当前屏幕中
    shutdown -h now       #计算机会立刻关机
    shutdown -h 22:22     #计算机会在这个时刻关机
    shutdown -r now        #计算机会立刻重启
    shutdown -r +10         #计算机会将于10分钟后重启
    reboot                           #重启
    halt                                #关机

> 2、新打开一个xsheel窗口 然后把kafka杀掉。

终、、

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

以上就是linux安装kafka方法，有什么问题可以联系我哈。

鼓励作者写出更好的技术文档，就请我喝一瓶哇哈哈哈哈哈哈哈。。你们的赞助决定我更新的速度哦！

微信：

[![format_png][]][format_png 1]

支付宝：

[![format_png 2][]][format_png 2 1]

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

感谢一路支持我的人。。。。。
    
    Love me and hold me
    QQ:69673804（16年老号）
    EMAIL:itw@tom.com
    友链交换
    如果有兴趣和本博客交换友链的话，请按照下面的格式在评论区进行评论，我会尽快添加上你的链接。

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

网站名称：KingYiFan’S Blog
    网站地址：http://blog.cnbuilder.cn
    网站描述：年少是你未醒的梦话，风华是燃烬的彼岸花。
    网站Logo/头像： [头像地址](https://blog.cnbuilder.cn/upload/2018/7/avatar20180720144536200.jpg)

[zookeeper]: https://blog.cnbuilder.cn/archives/linuxinstallzookeeper
[file]: /images/20220114/61a346daa01349cb87df06aa3ccdb05f.png
[file 1]: /images/20220114/127a7bd9af964d90ada8d22570d60a0d.png
[file 2]: /images/20220114/97c0496f199142108d1473988a788917.png
[file 3]: /images/20220114/edf34414389f45f38f5d6cadb77e57f3.png
[file 4]: /images/20220114/0c1725c7973c4a068e00f799b6571740.png
[file 5]: /images/20220114/d39bb3726f7c4f56b6d75c19de8200db.png
[file 6]: /images/20220114/57276c62161f492fade64c7fe87c998d.png
[file 7]: /images/20220114/8f950c6a6c65429e82b3dd751d8b6f6e.png
[file 8]: /images/20220114/8def6b740dab49c0b0b2d83120ed0285.png
[file 9]: /images/20220114/ef376f8b0aa94394a4198255a2614fdf.png
[file 10]: /images/20220114/ea58a4954cae4f06b2c1de8c04c35323.png
[file 11]: /images/20220114/caf7d9af355e4b988ec83cc53f2a96ab.png
[file 12]: /images/20220114/0080f2801f804f7c94bf32f3a719a5f1.png
[file 13]: /images/20220114/1dfa733f82fe4a58962f0e22592f2a18.png
[file 14]: /images/20220114/927f8c4c0f194bd8b039fb7749e7ae0b.png
[file 15]: /images/20220114/1a88ebc0eff64ce186367ea3154065f6.png
[file 16]: /images/20220114/60a2fb10008549e9959a480f5d31ade1.png
[file 17]: /images/20220114/6e250ae380dc4409911fa0ab1fd75a18.png
[file 18]: /images/20220114/8dce150dd4234958aebbcec3a3449a50.png
[file 19]: /images/20220114/7f69ba6343f1444db3c213fcfb3fcd01.png
[file 20]: /images/20220114/39b7e2062c9045d3900ddcedbbbb5c3e.png
[file 21]: /images/20220114/de184a5976034615b1d3662fc762d02d.png
[file 22]: /images/20220114/1039771c60d84e388974eef8ad88051b.png
[file 23]: /images/20220114/71dec247bf914a098a4a873721ffb829.png
[format_png]: /images/20220114/4d7deba55e0844479994b607ede9bdd0.png
[format_png 1]: http://blog.cnbuilder.cn/upload/2018/7/%E5%BE%AE%E4%BF%A1%E5%9B%BE%E7%89%87_20180718143757_meitu_220180718150018666.jpg
[format_png 2]: /images/20220114/576c183fd9c447518a005f093f82056e.png
[format_png 2 1]: http://blog.cnbuilder.cn/upload/2018/7/%E5%BE%AE%E4%BF%A1%E6%88%AA%E5%9B%BE_2018071814381620180718143910635.png