kafka的基本使用

使用kafka代理及zookeeper完成队列模式的消息传输实例。

下载kafka、zookeeper解压完成后配置环境变量

信件系统变量,如下,自己的zookeeper路径

 

再将bin的路径放入path中

在conf复制zoo_sample.cfg改名为zoo.cfg

 

进入zoo.cfg修改dataDir的路径,为自己的zookeeper的根目录

 

在kafka的config中找到server.properties

 

打开该文件,找到log.dirs,将log.dirs的路径改为自己的kafka根目录

输入zkserver

看到

表示成功启动

输入.kafka-server-start.bat ....configserver.properties

看到started表明kafka成功启动

.kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

出现Created topic "test".表示成功。

输入.kafka-console-producer.bat --broker-list localhost:9092 --topic test创建生产者

输入.kafka-console-consumer.bat --zookeeper localhost:2181 --topic test创建消费者

在生产者中输入消息,

消费者收到生产者发送的消息

 

 

原文地址:https://www.cnblogs.com/baimafeima/p/12416956.html