server.properties 中修改log地址:
zookeeper.properties 中指定数据存储地址：
在kafka_2.13-3.1.0binwindows目录下
启动自带的zk：
zookeeper-server-start.bat ....configzookeeper.properties
启动server:
kafka-server-start.bat ....configserver.properties
创建一个topic:
kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
生产者发送消息:
kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test
消费者接收消息:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
下载源码后导入idea，同样去修改配置文件中data和log文件的地址，文件路径分隔符要用“”，idea下启动Kafka下main方法报错：
Process 'command 'D:/JAVA/jdk-11.0.14/bin/java.exe'' finished with non-zero exit value 1
可以点击 Run with --scan 看到详细报错信息，先报的错是：
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
没有日志的实现类，搜了下代码里发现了这样一段说明
在build.gradle中加入一个日志的实现依赖
implementation 'com.newrelic.logging:logback:2.3'
启动一个zookeeper后就能在idea里面启动kafka里的main方法了