Kafka安装

原创
2017/03/22 19:30
阅读数 150

1、安装JDK(1.8.x)

2、安装zookeeper

    a. 下载zookeeper-3.4.9.tar.gz

    b. 解压到D:\Install目录下

    c. 进入D:\Install\zookeeper-3.4.9\conf目录,将zoo_sample.cfg重名为zoo.cfg,并做以下修改:

dataDir=D:/Install/zookeeper-3.4.9/data
clientPort=2181

    d. 双击D:\Install\zookeeper-3.4.9\bin目录下的zkServer.cmd启动zookeeper

#linux下启动zookeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties

3、安装Kafka

    a. 下载kafka_2.11-0.10.1.1.tgz

    b. 解压到D:\Install目录下

    c. 进入D:\Install\kafka_2.11-0.10.1.1\config

        修改server.properties:

log.dirs=D:/tmp/kafka-logs

    修改zookeeper.properties

dataDir=d:/tmp/zookeeper

    d. 进入D:\Install\kafka_2.11-0.10.1.1,启动Kafka服务

#window
.\bin\windows\kafka-server-start.bat .\config\server.properties

#linux
./bin/kafka-server-start.sh ./config/server.properties

    e. 创建topic,=> kafka-spark-demo

#window
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

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

    f. 查看topic   

#window
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

#linux
./bin/kafka-topics.sh --list --zookeeper localhost:2181

    g. 启动Producer

#window
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

#linux
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

    h. 启动Comsumer

#window
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --from-beginning --topic test

#linux
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic test

    i. 测试,在Producer上输入消息,即可在Consumer上面看到输出

4、Kafka其他命令

#删除topic
./bin/kafka-topics.sh  --delete --zookeeper localhost:2181 --topic test

 

展开阅读全文
打赏
1
2 收藏
分享
加载中
更多评论
打赏
0 评论
2 收藏
1
分享
返回顶部
顶部