您的位置:首页 > 其它

Kafka单机安装

2015-11-04 00:24 316 查看
前提条件:安装zookeeper,见下文

http://blog.csdn.net/jameshadoop/article/details/49621709

环境:

centos 6.5 x64

kafka_2.9.2-0.8.1.1

1.解压

tar -xzf kafka_2.9.2-0.8.1.1.tgz

2.启动

2.1要先启动zookeeper

sh $zookeeper_home/bin/zkServer.sh start


2.2启动kafka

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


3测试

创建 topic:

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


通过list命令查看创建的topic:

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


生产消息:

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


此时随便输入一条消息并回车

I’m James

消费消息:

另启动一个窗口

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


I’m James

4.停止kafka

停止Kafka server

bin/kafka-server-stop.sh


停止Zookeeper server:

sh $zookeeper_home/bin/zkServer.sh stop


结束
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  zookeeper kafka