zookeeper-kafka 单机安装
Posted bluss-yang
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了zookeeper-kafka 单机安装相关的知识,希望对你有一定的参考价值。
https://blog.csdn.net/helloworldyangsong/article/details/99180690
https://blog.csdn.net/Mr_XiMu/article/details/102021121
一、zookeeper安装
1、下载
2、解压
sudo tar -zxvf apache-zookeeper-3.6.1-bin.tar.gz
3、进入zookeeper目录
-
cd /usr/web/apache-zookeeper-3.6.1-bin
-
mkdir data
4、更改配置
-
cd /usr/web/apache-zookeeper-3.6.1-bin/conf
-
将默认配置 cp zoo_sample.cfg zoo.cfg
-
zoo.cfg
改配置:
dataDir=/usr/web/apache-zookeeper-3.6.1-bin/data
server.1=ip:2888:3888
二、kafka的安装
1、下载
2、解压
/usr/web/kafka_2.11-2.4.1
3、修改配置
-
cd
/usr/web/kafka_2.11-2.4.1/config/
-
sudo vim server.properties
-
加配置
-
listeners=PLAINTEXT://ip:9092
-
advertised.listeners=PLAINTEXT://ip:9092
-
zookeeper.connect=ip:2181
4.配置启动文件
vi zook_kafka_start.sh
#启动zookeeper
/usr/web/apache-zookeeper-3.6.1-bin/bin/zkServer.sh start &
#等3秒后执行
sleep 6
#启动kafka
/usr/web/kafka_2.11-2.4.1/bin/kafka-server-start.sh -daemon /usr/web/kafka_2.11-2.4.1/config/server.properties
vi zook_kafka_stop.sh
#启动zookeeper
/usr/web/apache-zookeeper-3.6.1-bin/bin/zkServer.sh stop&
#等3秒后执行
sleep 6
#启动kafka
/usr/web/kafka_2.11-2.4.1/bin/kafka-server-stop.sh -daemon /usr/web/kafka_2.11-2.4.1/config/server.properties
5、使用
①:创建一个名为“test”的Topic,只有一个分区和一个备份:(ip需要和config/server.properties的保持一致)
bin/kafka-topics.sh --create --zookeeper (Linux的ip):2181 --replication-factor 1 --partitions 1 --topic test
②、查看已创建的topic信息:(ip需要和config/server.properties的保持一致)
> bin/kafka-topics.sh --list --zookeeper (Linux的ip):2181
③、开启生产者发送消息:(ip需要和config/server.properties的保持一致)
bin/kafka-console-producer.sh --broker-list (Linux的ip):9092 --topic test
④:开启消费者消费消息:(ip需要和config/server.properties的保持一致)
bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic test --from-beginning
以上是关于zookeeper-kafka 单机安装的主要内容,如果未能解决你的问题,请参考以下文章