02-windows下kafka的基本使用

环境准备

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

KafKA使用

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

启动ZK

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

启动KAFKA

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

测试Kafka命令

• 创建一个主题

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

• 查看创建的主题列表

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

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

• 启动生产者：

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

• 启动消费者：

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

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

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