您的位置:首页 > 其它

kafka笔记(常用的一些命令,和安装测试!)

2018-03-08 13:28 399 查看
1.启动kafka (如果加入'>>/dev/null')表示所有的内容都会丢失,而且不保存,也就是我们听过的“黑洞”的意思,如果后面再加上一个
&   表示后台运行

bin/kafka-server-start.sh config/server.properties >>/dev/null 2>&1 &

2.启动zookeeper(kafka自带的)
bin/zookeeper-server-start.sh config/zookeeper.properties &

3.创建一个topic(名字为mytopic)
bin/kafka-topics.sh --create --topic mytopic --replication-factor 1 --partitions 1 --zookeeper localhost:2181

4.查看所有topic
bin/kafka-topics.sh --zookeeper bogon:2181 --list
5.查看mytopic的详情信息
bin/kafka-topics.sh --describe --topic mytopic --zookeeper localhost:2181


6.创建消费者
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytopic --from-beginning

7.创建生产者
bin/kafka-console-producer.sh --topic mytopic --broker-list localhost:9092

安装测试kafka(测试自带的zookeeper)

先将kafka拉倒Linux中;

如果拉不进来,在Linux终端输入 yum install lrzsz

拉进来以后,解压kafka

tar -zxvf kafka_2.11-0.11.0.2.tgz -C /usr/local/然后根据自己喜好改名
mv kafka_2.11-0.11.0.2/ kafka


然后什么都不需要做,直接启动zookeeper,再启动kafka(命令上面都有)
然后在打开一个窗口(一共需要四个任务窗口一个zookeeper,一个kafka,一个消费者,一个生产者)

然后在消费者窗口创建一个topic(命令如上)

再启动消费者(命令如上)启动好了后,不要关闭此窗口,他会卡在这里等待接收数据

然后打开生产者,(启动生产者命令如上;),然后你会发现生产者和消费者一样卡主不动了,但是你细细观察会发现生产者有一个 > 号,可以输入数据,当我们输入数据后,那么再去看看消费者里面,它就会接收到生产者的数据,那么简单的测试就成功了;
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: