码迷,mamicode.com
首页 > 其他好文 > 详细

kafka部署

时间:2016-08-18 23:04:34      阅读:116      评论: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
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!