安装软件

JDK

zookeeper

kafka

测试kafka

打开zookeeper

zkserver

打开kafka

cd D:\bigdata\home\kafka_2.12-2.4.0

.\bin\windows\kafka-server-start.bat .\config\server.properties

新建主题

cd  D:\bigdata\home\kafka_2.12-2.4.0\bin\windows

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

创建生产者

kafka-console-producer.bat --broker-list localhost:9092 --topic testdp

创建消费者

cd  D:\bigdata\home\kafka_2.12-2.4.0\bin\windows

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic testdp --from-beginning