Kafka消息队列初识 (3)

  下载地址:,找到下边的Binary Downloads就行了,版本随意选择,不过最好选择比较旧一点了,以防新的版本有新的改动啥的,导致我们踩坑,我选了下边这个版本:

  

Kafka消息队列初识

  下载之后直接解压就行了,压缩包格式是在linux上用的,不过一般的我们学习一个东西都可以先从windows上开始, 操作起来比较简单,由于这种高级东西运行起来都是命令行,所以对于linux和windows就没啥区别的了,到linux也是命令直接复制粘贴就行了。

  

Kafka消息队列初识

2.2 启动Kakfa

  2.2.1 启动Zookeeper

  因为Kafka依赖Zookeeper,所以要先启动它,如下图,定位到Kafka的目录,我的是 F:\Dev\kafka_2.11-2.1.0。

  

Kafka消息队列初识

  在地址栏中输出cmd,然后敲回车,瞬间打开一个命令行,然后输入:.\bin\windows\zookeeper-server-start.bat   .\config\zookeeper.properties,注意. 代表当前目录,使用这个bat启动Zookeeper并且使用后边的配置。

  

Kafka消息队列初识

  发现上边那句话,并且没报错什么的,表示Zookeeper启动成功。

  2.2.2 启动Kafka

  同样,在地址栏中输出cmd,瞬间启动一个命令行,然后输入:.\bin\windows\kafka-server-start.bat .\config\server.properties

   

Kafka消息队列初识

  发现上边那句话,并且没报错什么的,表示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。

  

Kafka消息队列初识

  发现上边那句话,并且没报错什么的,表示主题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的消息

  

Kafka消息队列初识

  出现一个光标,表示等待生产消息,一会我们可以输入消息。

  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的消息

  

Kafka消息队列初识

  也会出现一个光标,等待显示消息。

  2.2.6 测试生产和消费

  在Producer控制台输入消息,会在Consumer控制台看见消息:

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zydspw.html