使用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创建消费者
在生产者中输入消息,
消费者收到生产者发送的消息