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 ..\..\config\server.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创建消费者

在生产者中输入消息，

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

kafka的基本使用

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