下载地址:,找到下边的Binary Downloads就行了,版本随意选择,不过最好选择比较旧一点了,以防新的版本有新的改动啥的,导致我们踩坑,我选了下边这个版本:
下载之后直接解压就行了,压缩包格式是在linux上用的,不过一般的我们学习一个东西都可以先从windows上开始, 操作起来比较简单,由于这种高级东西运行起来都是命令行,所以对于linux和windows就没啥区别的了,到linux也是命令直接复制粘贴就行了。
2.2 启动Kakfa
2.2.1 启动Zookeeper
因为Kafka依赖Zookeeper,所以要先启动它,如下图,定位到Kafka的目录,我的是 F:\Dev\kafka_2.11-2.1.0。
在地址栏中输出cmd,然后敲回车,瞬间打开一个命令行,然后输入:.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties,注意. 代表当前目录,使用这个bat启动Zookeeper并且使用后边的配置。
发现上边那句话,并且没报错什么的,表示Zookeeper启动成功。
2.2.2 启动Kafka
同样,在地址栏中输出cmd,瞬间启动一个命令行,然后输入:.\bin\windows\kafka-server-start.bat .\config\server.properties
发现上边那句话,并且没报错什么的,表示Kafka启动成功。
2.2.3 创建Topic
同样,进入到F:\Dev\kafka_2.11-2.1.0\bin\windows,在地址栏中输出cmd,瞬间启动一个命令行,然后输入:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test,创建一个主题test。
发现上边那句话,并且没报错什么的,表示主题Topic创建成功。
2.2.4 创建Producer
同样,进入到F:\Dev\kafka_2.11-2.1.0\bin\windows,在地址栏中输出cmd,瞬间启动一个命令行,然后输入:kafka-console-producer.bat --broker-list localhost:9092 --topic test,创建一个Producer,准备生产主题为test的消息。
出现一个光标,表示等待生产消息,一会我们可以输入消息。
2.2.5 创建Consumer
同样,进入到F:\Dev\kafka_2.11-2.1.0\bin\windows,在地址栏中输出cmd,瞬间启动一个命令行,然后输入:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning,创建一个Consumer,准备消费主题为test的消息。
也会出现一个光标,等待显示消息。
2.2.6 测试生产和消费
在Producer控制台输入消息,会在Consumer控制台看见消息: