配置修改
kafka_2.13-3.4.0\config下面
zookeeper.properties
clientPort=2181
maxClientCnxns=0
admin.enableServer=true
admin.enable=true
audit.enable=true
dataDir=E:/kafka_2.13-3.4.0/zookeeper_data
dataLogDir=E:/kafka_2.13-3.4.0/zookeeper_logserver.properties
log.dirs=E:/kafka_2.13-3.4.0/logs
zookeeper.connect=localhost:2181启动Zookeeper
.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
启动服务
.\bin\windows\kafka-server-start.bat .\config\server.properties
启动生产者
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic user启动消防者监听消息
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic user