kafka集群搭建&zookeeper集群搭建

kafka集群搭建&zookeeper集群搭建1.安装准备jdk-8u162-linux-x64.tarzookeeper-3.4.12.tar.gzkafka_2.11-2.0.0.tgz2.准备至少三台虚拟机192.168.196.128192.168.196.131192.168.196.1323.Java环境安装(略…自行百度)4.搭建zookeeper集群在每台主机下执行以下步骤:移动至/usr/local下:mvzookeeper-3.4.12.tar.gz/usr/local解压,重命名:tar-z

大家好,又见面了,我是你们的朋友全栈君。

1.安装准备
jdk-8u162-linux-x64.tar
zookeeper-3.4.12.tar.gz
kafka_2.11-2.0.0 .tgz

2.准备至少三台虚拟机
192.168.196.128
192.168.196.131
192.168.196.132

3.Java环境安装
(略…自行百度)

4.搭建zookeeper集群
在每台主机下执行以下步骤:

移动至/usr/local下:

mv zookeeper-3.4.12.tar.gz /usr/local

解压,重命名:

tar -zxvf zookeeper-3.4.12.tar.gz
mv zookeeper-3.4.12 zookeeper

配置环境变量:

vim /etc/profile

追加以下内容:

#set zookeeper environment
export ZK_HOME=/usr/local/zookeeper
export PATH=$ZK_HOME/bin:$PATH

保存文件后,使修改生效:

source /etc/profile

打开zookeeper配置文件:

cp /usr/local/zookeeper/conf/zoo_sample.cfg /usr/local/zookeeper/conf/zoo.cfg
vim /usr/local/zookeeper/zoo.cfg

修改zookeeper配置文件:

#修改数据文件夹路径
dataDir=/usr/local/zookeeper/data
#在文件末尾添加
server.1=192.168.196.128:2888:3888
server.2=192.168.196.131:2888:3888
server.3=192.168.196.132:2888:3888

创建数据文件夹和myid文件:

mkdir /usr/local/zookeeper/data
touch /usr/local/zookeeper/data/myid

分别在各个机器添加myid信息:

echo "1" > /usr/local/zookeeper/data/myid #kafka-1 192.168.196.128
echo "2" > /usr/local/zookeeper/data/myid #kafka-1 192.168.196.131
echo "3" > /usr/local/zookeeper/data/myid #kafka-1 192.168.196.132

分别在各个机器启动zookeeper:

/usr/local/zookeeper/bin/zkServer.sh start

全部启动后查看状态:

 /usr/local/zookeeper/bin/zkServer.sh status

显示如下则zookeeper集群搭建成功:
在这里插入图片描述在这里插入图片描述在这里插入图片描述
5.搭建kafka集群
在每台主机下执行以下步骤:
移动至/usr/local下:

mv kafka_2.11-2.0.0 .tgz /usr/local

解压,重命名:

tar -zxvf kafka_2.11-2.0.0 .tgz
mv kafka_2.11-2.0.0 kafka

配置环境变量:

vim /etc/profile

追加以下内容:

#set kafka environment
export KAFKA_HOME=/usr/local/kafka
export PATH=${KAFKA_HOME}/bin:$PATH

保存文件后,使修改生效:

source /etc/profile

修改server.properties配置文件:

vim /usr/local/kafka/config/server.properties

在kafka-1主机中:

#修改
broker.id=1
listeners=PLAINTEXT://192.168.196.128:9092
zookeeper.connect=192.168.196.128:2181,192.168.196.131:2181,192.168.196.132:2181
offsets.topic.replication.factor=3

在kafka-2主机中:

#修改
broker.id=2
listeners=PLAINTEXT://192.168.196.131:9092
zookeeper.connect=192.168.196.128:2181,192.168.196.131:2181,192.168.196.132:2181
offsets.topic.replication.factor=3

在kafka-3主机中:

#修改
broker.id=3
listeners=PLAINTEXT://192.168.196.132:9092
zookeeper.connect=192.168.196.128:2181,192.168.196.131:2181,192.168.196.132:2181
offsets.topic.replication.factor=3

在每台机器上分别启动kafka

/usr/local/kafka/bin/kafka-server-start.sh -daemon config/server.properties

(测试)在其中一台机器上创建topic:

/usr/local/kafka/bin/kafka-topics.sh --create --zookeeper 192.168.196.128:2181,192.168.196.131:2181,192.168.196.132:2181 --replication-factor 3 --partitions 3 --topic test-topic

(测试)查看创建的topic信息:

/usr/local/kafka/bin/kafka-topics.sh --describe --zookeeper 192.168.196.128:2181,192.168.196.131:2181,192.168.196.132:2181 --topic test-topic

(测试)选其中一台机器创建生产者:

bin/kafka-console-producer.sh --broker-list 192.168.196.128:9092 -topic test-topic

(测试)另外两台机器创建消费者:

bin/kafka-console-consumer.sh --bootstrap-server 192.168.196.128:9092,192.168.196.131:9092,192.168.196.132:9092 --topic test-topic2 --from-beginning

尝试发送消息,收到则部署成功!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/134087.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • C语言中的移位运算

    C语言中的移位运算移位运算移位运算包括左移和右移左移运算:x<<k:x左移k位,并在右端补零。右移运算:逻辑右移:x>>k:x右移k位,并在左端补零。算术右移:x>>k:x右移k位,并在左端补最高有效位的值。下表为对一个8位参数x的两个不同的值做不同的一位操作得到的结果:操作值参数x[01100011][10010101]x&l

  • python & 0xFFFFFFFF打印输出负数的补码[通俗易懂]

    python & 0xFFFFFFFF打印输出负数的补码[通俗易懂]-7的有符号原码和补码表示-7的原码:0b10000111(8位)-7的补码:0b11111001(8位)python中的输出a=-7print(bin(a))#输出-0b111python直观地打印输出了带负号的原码显示为了能够打印输出对应的补码表示进行如下运算:a=-7b=a&0xFF#-7的补码print(b)#249print(0b11111001)print(bin(b)#输出249//249原码0

  • tomcat启动时错误:Failed to start component [StandardEngine[Catalina].StandardHost[localhost].错误

    tomcat启动时错误:Failed to start component [StandardEngine[Catalina].StandardHost[localhost].错误tomcat启动时错误:Failed to start component [StandardEngine[Catalina].StandardHost[localhost].错误

  • cd4与cd8比值的意义 化疗后_艾滋病人的cd8高好还是低好

    cd4与cd8比值的意义 化疗后_艾滋病人的cd8高好还是低好正常情况下CD4/CD8比值介于1.5—2.5之间,如CD4是每微升血750个,CD8是每微升血460个,这样两者的比值就是1.63。虽然95%的正常人CD4/CD8的比值都在1以上,但是也有一些正

  • DOS命令COPY与XCOPY有什么区别「建议收藏」

    DOS命令COPY与XCOPY有什么区别「建议收藏」内部命令COPY与外部命令XCOPY在作用及使用方法上有什么区别?首先说一下内外部命令的区别,内部命令是在启动DOS后调入计算机内存中常驻的,外部命令是刻在磁盘上面的,使用时内部命令可以在每一个盘符下从内存直接执行,而外部命令执行时除了外部命令所在目录及设定好路径的盘符下执行外,在其它位置执行都需要指明此命令所在路径,执行时都是从磁盘调入内存来执行。至于COPY和XCOPY的区别是:用

  • pycharm用anaconda的Python_pycharm配置anaconda环境

    pycharm用anaconda的Python_pycharm配置anaconda环境先附上链接两个,是我自己用的pycharm链接:https://pan.baidu.com/s/1O5PixlPNpUw3RcxYbHHdBQ密码:vgjy下面是我自己用的Anaconda,版本是Anaconda2-5.0.1-Windows-x86_64链接:https://pan.baidu.com/s/16jiiYDtH9pVZTz6Ix7FeIQ密码:0yzmAnaco…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号