Centos 7 安装zookeeper + kafka单机例子

港控/mmm° 2021-10-01 00:22 375阅读 0赞

写的不好主要是为了自己看

下载好zookeeper和kafka后，解压好后

先开始zookeeper

打开conf中有一个zoo\_sample.cfg复制此文件改为名字zoo.cfg

修改zoo.cfg

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pY3Jvb3BpdGhlY3Vz_size_16_color_FFFFFF_t_70][]

vim /etc/profile

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pY3Jvb3BpdGhlY3Vz_size_16_color_FFFFFF_t_70 1][]

在末尾加入如图

#idea - zookeeper-3.4.9 config start - 2017-12-09
    export ZOOKEEPER_HOME=/usr/local/services/zookeeper/zookeeper-3.4.9/
    export PATH=$ZOOKEEPER_HOME/bin:$PATH
    export PATH
    #idea - zookeeper-3.4.9 config end - 2017-12-09

source /etc/profile

启动 zookeeper 服务：  
zkServer.sh start

查询 zookeeper 状态：  
zkServer.sh status  
  
关闭 zookeeper 服务：  
zkServer.sh stop

重启 zookeeper 服务：  
zkServer.sh restart

以上是zookeeper，下面是kafka

下载解压不写

vim server.properties

主要更改

log.dirs=/usr/local/kafka\_2.12-2.1.0/logs/kafka  
listeners=PLAINTEXT://（你的ip）:9092

zookeeper.connect=114.67.100.229:2181

启动

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

查看线程

netstat -tunlp|egrep "(2181|9092)"

创建topic

./bin/kafka-topics.sh --create --zookeeper ip:2181 --replication-factor 1 --partitions 1 --topic test-topic

生产者：

./bin/kafka-console-producer.sh --broker-list ip:9092 --topic test\_topics

消费者：

./bin/kafka-console-consumer.sh --bootstrap-server ip:9092 --topic test\_topics --from-beginning

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pY3Jvb3BpdGhlY3Vz_size_16_color_FFFFFF_t_70]: /images/20210923/03a50c1d85d04cac9bf05cb8dc7c02da.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21pY3Jvb3BpdGhlY3Vz_size_16_color_FFFFFF_t_70 1]: /images/20210923/27f6ff06b4414dbf881aadef87f49dd7.png