首页 > 其他 > 详细

kafka部署

时间:2016-08-18 23:01:40      阅读:157      评论:0      收藏:0      [点我收藏+]
step1 压缩包 kafka_2.9.2-0.8.1.1.czj.zip
 
step2:解压
unzip kafka_2.9.2-0.8.1.1.czj.zip
进入kafka_2.9.2-0.8.1.1: (以后执行命令在此路径下)
cd kafka_2.9.2-0.8.1.1
修改配置文件config/server.properties:
vim config/server.properties
属性:
broker.id=0 (随便)
host.name=hadoop03 (自己的主机 也可以是ip地址)
zookeeper.connect=hadoop03:2181 (自己的主机 也可以是ip地址,注意要统一)
 
step3: 确保有执行权限
chmod +x sbin/*
chmod +x bin/*
 
Step5:启动kafka服务
sbin/start-kafka.sh
查看是否启动: jsp -ls
启动成功会出现 kafka字样
 
tep6.创建topic主题:
bin/kafka-topics.sh --create --zookeeper hadoop03:2181 --replication-factor 1 --partitions 1 --topic mytopic (hadoop03 主机名 mytopic 主题名)
启动consumer
bin/kafka-console-consumer.sh --zookeeper hadoop03:2181 --topic mytopic
启动productor
bin/kafka-console-producer.sh --broker-list hadoop03:9092 --topic mytopic
 
在productor端输入,看consumer端的输出。
 

kafka部署

原文:http://www.cnblogs.com/ailonglong/p/kafaka.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!