image

最近公司用kafka,本地需要测试测试,本地为windows环境,因此学习一下windows下对kafka的基本操作,便于代码的调试,也是作为知识的记录。

环境准备

  • JDK8自行下载
  • kafka下载【我自己用的是以前下载的版本,为 kafka_2.11-2.1.0.tgz 这个版本,直接下载解压即可】

KafKA使用

由于是windows环境,解压之后我们的注意点是kafka_2.11-2.1.0\bin\windows目录。

image

启动ZK

在此目录下打开cmd,执行命令zookeeper-server-start.bat ..\..\config\zookeeper.properties,如下图表示启动成功:

image

启动KAFKA

依旧在目录下打开cmd,执行命令kafka-server-start.bat ..\..\config\server.properties,如下图表示启动成功:

image

测试Kafka命令
  • 创建一个主题

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic TOPIC的名称

  • 查看创建的主题列表

kafka-topics.bat --list --zookeeper localhost:2181

我这里新建一个叫做test的topic作为实验。

image

  • 启动生产者:

kafka-console-producer.bat --broker-list localhost:9092 --topic test

  • 启动消费者:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

此时可以从控制台输入信息,待消费者即可接收到生产者发布的消息。

image

至此,最基本的操作介绍完毕!