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、下载

https://zookeeper.apache.org/

2、解压

sudo tar -zxvf apache-zookeeper-3.6.1-bin.tar.gz

 

3、进入zookeeper目录

  1. cd /usr/web/apache-zookeeper-3.6.1-bin

  2. mkdir data

4、更改配置

  1. cd /usr/web/apache-zookeeper-3.6.1-bin/conf

  2. 将默认配置 cp zoo_sample.cfg  zoo.cfg

  3. zoo.cfg

改配置:

dataDir=/usr/web/apache-zookeeper-3.6.1-bin/data


server.1=ip:2888:3888

二、kafka的安装

1、下载

http://kafka.apache.org/

2、解压

/usr/web/kafka_2.11-2.4.1

3、修改配置

  1. cd /usr/web/kafka_2.11-2.4.1/config/

  2. sudo vim server.properties

  3. 加配置

  4.  listeners=PLAINTEXT://ip:9092

  5.  advertised.listeners=PLAINTEXT://ip:9092

  6.  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 单机安装的主要内容,如果未能解决你的问题,请参考以下文章

zookeeper-kafka(集群版)安装部署以及java调用工具类

zookeeper-kafka集群部署总结篇

如何安装 速达3000单机版SQL server 数据库?

Docker(单机Kafka安装)

Redis单机环境安装

安装-单机