1.首先安装并启动zk,我们假设启动端口为2181
2.下载kafka版本：我们使用scala2.11的版本
3.修改server.properties把 log.dirs的值改成你对应的目录：比如我这里的:log.dirs=D:kafkakafka_2.11-2.4.1kafka-logs,D:kafkakafka_2.11-2.4.1kafka-logs
4.启动kafka服务器：
5.启动生产者和消费者测试:
参考文献：https://www.cnblogs.com/lnice/p/9668750.html
https://chenchenchen.blog.csdn.net/article/details/91893910?spm=1001.2101.3001.6650.2&utm_medium=distribute.pc_relevant.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-2.pc_relevant_default&depth_1-utm_source=distribute.pc_relevant.none-task-blog-2%7Edefault%7ECTRLIST%7ERate-2.pc_relevant_default&utm_relevant_index=5
