windwos 安装下kafka的安装使用

依赖环境java 1.8

必须下载软件
zookeeper
kafka

• 首先创建目录目录:E:igdata,将下载的2个软件放入目录,依次修改配置如下:E:igdatakafka_2.11-2.1.1configzoo.cfg(zoo_sample.cfg重命名得到) 修改:dataDir=E:/bigdata/zookeeper-3.4.10/data

---

• 新建环境变量: ZOOKEEPER_HOME=E:igdatazookeeper-3.4.10,将此环境变量加入path,启动 cmd 执行: zkserver

---

• 安装kafka 修改 E:igdatakafka_2.11-2.1.1configserver.properties 修改: log.dirs=E:/bigdata/kafka_2.11-2.1.1/kafka-logs

---

• 启动kafka： E:igdatakafka_2.11-2.1.1>binwindowskafka-server-start.bat .configserver.properties

.inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test  创建主题

.inwindowskafka-topics.bat --list --zookeeper localhost:2181 查看主题

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

.inwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning 创建消费者