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

至此，最基本的操作介绍完毕！