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的详情信息
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(命令如上)
再启动消费者(命令如上)启动好了后,不要关闭此窗口,他会卡在这里等待接收数据
然后打开生产者,(启动生产者命令如上;),然后你会发现生产者和消费者一样卡主不动了,但是你细细观察会发现生产者有一个 > 号,可以输入数据,当我们输入数据后,那么再去看看消费者里面,它就会接收到生产者的数据,那么简单的测试就成功了;
& 表示后台运行
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(命令如上)
再启动消费者(命令如上)启动好了后,不要关闭此窗口,他会卡在这里等待接收数据
然后打开生产者,(启动生产者命令如上;),然后你会发现生产者和消费者一样卡主不动了,但是你细细观察会发现生产者有一个 > 号,可以输入数据,当我们输入数据后,那么再去看看消费者里面,它就会接收到生产者的数据,那么简单的测试就成功了;
相关文章推荐
- Kafka笔记-2-kafka安装步骤及常用命令
- [原]一些KVM测试过程中的命令笔记(2)分配实例
- Linux之ubuntu学习笔记(二):一些常用快捷键和相关命令来控制系统任务ctr+z,ctr+c,ctrl+d
- 整理个人笔记Linux的一些常用命令
- kafka安装及常用命令
- 一些常用的MySQL命令脚本笔记
- 写得蛮好的linux学习笔记(二)(一些常用的基本命令)
- 一些常用到的linux命令整理笔记
- PostgreSql 学习笔记一 CentOS下安装使用 及常用命令
- Redis总结笔记(一):安装和常用命令
- Redis总结笔记(一):安装和常用命令
- 写得蛮好的linux学习笔记(一些常用的基本命令)
- Ubuntu下安装Docker,及Docker的一些常用命令操作
- Ubuntu 14 安装jdk8,MySql的安装卸载等一些常用的命令
- linux追加模块的网卡驱程 和 一些常用的命令笔记
- RHCE课程-RH033Linux基础笔记二之安装LINUX及常用命令介绍 推荐
- Apple:如何在iphone、ipad上安装一些常用命令行命令
- hadoop 安装ssh时用到的一些命令,查到的详细解释做个笔记
- linux下安装python linux下一些常用的命令
- [原]一些KVM测试过程中的命令笔记(1)