kafka基础操作

1.官网

　　http://kafka.apache.org/

2.介绍

　　一个分布式的流平台

3.特点

　　具有高吞吐量，高性能，实时，高可靠

二：安装

1.全部上传

　　

2.全部解压

　　

3.安装jdk

　　

4.zookeeper的安装

　　进入zookeeper的目录下的conf中

　　将zoo_sample.cfg拷贝一份zoo.cfg

　　

 　　启动：

　　

 　　

　　效果：

　　

  

5.kafka的安装

　　进入kafka的config目录

　　修改server.properties

　　

二：启动

1.启动kafka

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

　　

　　

2.停止

　　 ./bin/kafka-server-stop.sh 

3.创建topic

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

4.查看topic

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

　　

5.发送消息

　　./bin/kafka-console-producer.sh --broker-list 192.168.19.128:9092 --topic caojun-topic

　　

6.接受消息

　　kafka的地址：192.168.19.128:9092

　　./bin/kafka-console-consumer.sh --bootstrap-server 192.168.19.128:9092 --topic caojun-topic --from-beginning