kafka单机模式部署安装,zookeeper启动

Posted timxgb

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka单机模式部署安装,zookeeper启动相关的知识,希望对你有一定的参考价值。

 

 

 

  在root的用户下

1):前提 安装JDK环境,设置JAVA环境变量

2):下载kafka,命令:wget  http://mirrors.shuosc.org/apache/kafka/0.10.2.1/kafka_2.10-0.10.2.1.tgz

3):下载zookeeper,命令:wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

4):然后去解压zookeeper包,我把zookeeper-3.4.10文件夹名称改为了zookeeper ,首先找到conf的文件夹,然后备份一份zoo_sample.cfg文件 ,备份名为zoo.cfg

 命令:cp zoo_sample.cfg  zoo.cfg

5):打开zoo.cfg的文件

     命  令 :vim zoo.cfg   

dataDir=/tmp/zookeeper  (虽然给出这个路径给你,但是系统并没有,要你自己创建的,你可以不按这个路径)
dataLogDir=/tmp/zookeeperlog (这是我另外夹的用来存放日志文件)

6):启动 zookeeper 

[email protected]:/usr/local/zookeeper# 命令 :     bin/zkServer.sh start 

 技术分享图片

7)解压kafka的包,我把kafka_2.10-0.10.2.1文件夹名称改为了kafka,到config路径下找到 server.properties  

  找到log.dirs=/tmp/kafka-logs (跟刚刚zookeper一样创建) 

        listeners(所在机器ip地址)我这里是本地,不管它

8):启动kafka

命令:nohup bin/kafka-server-start.sh config/server.properties &

 运行之后不管成功否它都会在你的kafka包下生成一个 nohup.out的文件

9): 查看是否成功了

新建一个topic
命令:bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看 topic是否成功
命令:bin/kafka-topics.sh --list --zookeeper localhost:2181 

10):把kafka的生产者启动来 

命令 :bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

11):另开一个终端(创建新的),把消费者启动起来: 

命令:bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test —from-beginning

 

12):在生产者终端输入数据,消费者马上就会消费显示出来

 

生产者:

技术分享图片

消费者:

技术分享图片

 




以上是关于kafka单机模式部署安装,zookeeper启动的主要内容,如果未能解决你的问题,请参考以下文章

解开Kafka神秘的面纱:kafka单机部署和集群部署

解开Kafka神秘的面纱:kafka单机部署和集群部署

CentOS 7.2 中 Kafka,Zookeeper的单机部署,伪分布式部署以及真正的分布式部署

Kafka单机配置部署

kafka2.8.0版本(一):搭建部署

Kafka: Linux环境-单机部署和伪集群集群部署