cent os7 安装kafka

kafka下载地址：https://mirrors.bfsu.edu.cn/apache/kafka/2.6.0/kafka_2.13-2.6.0.tgz

前期准备：

cent os7 安装zookeeper3.6.0：https://blog.csdn.net/weixin_39816740/article/details/104995674

Kafka集群是把状态保存在Zookeeper中的，首先要搭建Zookeeper集群。

上传到目录/usr/local/java/下（rz,sz）解压

解压 tar -zxvf kafka_2.13-2.6.0.tgz

创建存放kafka日志目录 mkdir kafkalogs

跟zookeeper一样修改下文件名字 mv kafka_2.13-2.6.0 kafka

复制2份分别叫kafka2,kafka3

cp -r kafka kafka2
cp -r kafka kafka3

修改下文件名字，不小心整错了：

分别修改修改配置config/server.properties（3个kafka中的配置）

我的zookeeper的连接端口：10.108.3.61:2183,10.108.3.61:2182,10.108.3.61:2181

日志文件路经：/usr/local/java/kafka/kafkalogs

vim kafka/config/server.properties

broker.id=1 #当前机器在集群中的唯一标识，和zookeeper的myid性质一样
listeners=PLAINTEXT://10.108.3.61:9091  #监听的IP和端口
advertised.listeners=PLAINTEXT://10.108.3.61:9091
log.dirs=/usr/local/java/kafka/kafkalogs #消息存放的目录
zookeeper.connect=10.108.3.61:2183,10.108.3.61:2182,10.108.3.61:2181 #设置zookeeper的连接端口

另外两台机器同样配置，不过注意修改broker.id和ip和端口。

vim kafka2/config/server.properties

broker.id=2 #当前机器在集群中的唯一标识，和zookeeper的myid性质一样
listeners=PLAINTEXT://10.108.3.61:9092  #监听的IP和端口
advertised.listeners=PLAINTEXT://10.108.3.61:9092
log.dirs=/usr/local/java/kafka2/kafkalogs #消息存放的目录
zookeeper.connect=10.108.3.61:2183,10.108.3.61:2182,10.108.3.61:2181 #设置zookeeper的连接端口

vim kafka3/config/server.properties

broker.id=3 #当前机器在集群中的唯一标识，和zookeeper的myid性质一样
listeners=PLAINTEXT://10.108.3.61:9093  #监听的IP和端口
advertised.listeners=PLAINTEXT://10.108.3.61:9093
log.dirs=/usr/local/java/kafka3/kafkalogs #消息存放的目录
zookeeper.connect=10.108.3.61:2183,10.108.3.61:2182,10.108.3.61:2181 #设置zookeeper的连接端口

查看启动的zookeeper状态

依次启动 kafka

kafka/bin/kafka-server-start.sh kafka/config/server.properties &

kafka2/bin/kafka-server-start.sh kafka2/config/server.properties &

kafka3/bin/kafka-server-start.sh kafka3/config/server.properties &

查看是否启动成功

netstat -anp|grep 9091

netstat -anp|grep 9092

netstat -anp|grep 9093

创建主题（在kafka目录中）

kafka/bin/kafka-topics.sh --create --zookeeper 10.108.3.61:2181 --replication-factor 1 --partitions 1 --topic 主题名称

查看已有的主题

kafka/bin/kafka-topics.sh --list --zookeeper 10.108.3.61:2181

启动生产者做消息发布

kafka/bin/kafka-console-producer.sh --broker-list 10.108.3.61:9091 --topic ceshi

发布消息

另开一个窗口订阅消息并开启消费者（注意都是在kafka目录）

开启消费者订阅消息：

kafka/bin/kafka-console-consumer.sh --bootstrap-server 10.108.3.61:9091 --from-beginning --topic ceshi

大功告成！

删除topic

kafka/bin/kafka-topics.sh --delete --zookeeper 10.108.3.61:2181 --topic ceshi

查看删除成功

cent os7 安装kafka_2.13-2.6.0相关推荐

cent os7 安装dubbo-admin 管理控制台
dubbo官方文档地址:http://dubbo.apache.org/zh-cn/docs/admin/introduction.html 目前的管理控制台已经发布0.1版本,结构上采取了前后端分离 ...
如何在Cent OS7安装jdk
1.在Cent OS7中安装jdk,先查看cent os7中用的是多少位:查看代码:uname -i 我的是64位 2:https://www.oracle.com/technetwork/java/ ...
cent os7 安装elasticsearch-7.9.3（伪集群）和kibana-7.9.3
首先下载这4个软件:(版本要一致) 下载地址: https://artifacts.elastic.co/downloads/kibana/kibana-7.9.3-linux-x86_64.tar. ...
cent os7 安装zookeeper3.6.0
下载地址:https://zookeeper.apache.org/releases.html#download 上传到目录/usr/local/java/下(rz,sz)解压 cd到zookeepe ...
centen os7 安装并配置Nexus3.9.0
准备工作: jdk 1.8 nexus-3.9.0-01-unix.tar.gz(可以到官网上去下载最新版本的) 客户端安装了maven(注意下方的settings.xml是配置在本地的maven,不 ...
cent os7 安装nginx1.16.1
下载nginx安装包:http://nginx.org/en/download.html 上传下载的压缩包并解压查看gcc版本安装nginx所需要的依赖库 pcre是一个perl库,包括perl兼 ...
cent os7 安装jenkins(rpm)
下载地址: https://pkg.jenkins.io/redhat-stable/ (我的系统是linux centos7 所以下载这个 jdk要求8以上我安装的8) 下载速度慢试试命令 yu ...
Cent OS7的安装
一.为什么要学Linux 至于说为什么要学linux,对于普通来说用惯了windows,但是对于做IT工作的人来说,linux绝对是比不缺少的伙伴,它在服务器领域.嵌入式开发以及个人PC桌面等领域开始 ...
Cent os7 _ LINUX虚拟机安装_设置网络及图形化界面_安装教程
准备工具(可到官网去下载): 1.VMware Workstation 15.5.6 版本链接:https://pan.baidu.com/s/1o9w1Em91dYms0zR0fF7u3A 提取码 ...

cent os7 安装kafka_2.13-2.6.0

复制2份分别叫kafka2,kafka3

cent os7 安装kafka_2.13-2.6.0相关推荐

最新文章

热门文章