打开kafka_2.12-2.1.0\bin\windows目录,该目录下是所有windows命令:
在此目录下打开cmd,执行命令zookeeper-server-start.bat ....\config\zookeeper.properties,如下图:
zookeeper-server-start.bat ..\..\config\zookeeper.properties 2)、启动Kafka 依旧在目录下打开cmd,执行命令kafka-server-start.bat ....\config\server.properties,如下图: kafka-server-start.bat ..\..\config\server.properties OK,启动成功。注意:如果出现‘命令语法不正确’ ,导致不能正常运行,尝试修改配置文件的dataDir(zookeeper.properties),log.dirs(server.properties)。因为默认的是linux的文件目录格式。 如果运行中出现下面的错误,则是jdk的版本过低,至少要使用JDK8-jdk1.8.0_202这个版本。 JDK的全部版本下载地址: https://repo.huaweicloud.com/java/jdk/ 4、测试Kafka命令 1、创建一个主题 ## 命令1无法执行 kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic kafka-test-topic 2、查看创建的主题列表 ## 命令1无法执行 kafka-topics.bat --list --zookeeper localhost:2181 ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --list 3、启动生产者: kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
依旧在目录下打开cmd,执行命令kafka-server-start.bat ....\config\server.properties,如下图:
kafka-server-start.bat ..\..\config\server.properties OK,启动成功。注意:如果出现‘命令语法不正确’ ,导致不能正常运行,尝试修改配置文件的dataDir(zookeeper.properties),log.dirs(server.properties)。因为默认的是linux的文件目录格式。 如果运行中出现下面的错误,则是jdk的版本过低,至少要使用JDK8-jdk1.8.0_202这个版本。 JDK的全部版本下载地址: https://repo.huaweicloud.com/java/jdk/ 4、测试Kafka命令 1、创建一个主题 ## 命令1无法执行 kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic kafka-test-topic 2、查看创建的主题列表 ## 命令1无法执行 kafka-topics.bat --list --zookeeper localhost:2181 ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --list 3、启动生产者: kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
kafka-server-start.bat ..\..\config\server.properties OK,启动成功。注意:如果出现‘命令语法不正确’ ,导致不能正常运行,尝试修改配置文件的dataDir(zookeeper.properties),log.dirs(server.properties)。因为默认的是linux的文件目录格式。 如果运行中出现下面的错误,则是jdk的版本过低,至少要使用JDK8-jdk1.8.0_202这个版本。 JDK的全部版本下载地址:
OK,启动成功。注意:如果出现‘命令语法不正确’ ,导致不能正常运行,尝试修改配置文件的dataDir(zookeeper.properties),log.dirs(server.properties)。因为默认的是linux的文件目录格式。
如果运行中出现下面的错误,则是jdk的版本过低,至少要使用JDK8-jdk1.8.0_202这个版本。
JDK的全部版本下载地址:
https://repo.huaweicloud.com/java/jdk/ 4、测试Kafka命令 1、创建一个主题 ## 命令1无法执行 kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic kafka-test-topic 2、查看创建的主题列表 ## 命令1无法执行 kafka-topics.bat --list --zookeeper localhost:2181 ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --list 3、启动生产者: kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
https://repo.huaweicloud.com/java/jdk/
4、测试Kafka命令 1、创建一个主题 ## 命令1无法执行 kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic kafka-test-topic 2、查看创建的主题列表 ## 命令1无法执行 kafka-topics.bat --list --zookeeper localhost:2181 ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --list 3、启动生产者: kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
1、创建一个主题
## 命令1无法执行 kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic kafka-test-topic 2、查看创建的主题列表 ## 命令1无法执行 kafka-topics.bat --list --zookeeper localhost:2181 ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --list 3、启动生产者: kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
## 命令1无法执行 kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka-test-topic ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic kafka-test-topic 2、查看创建的主题列表
2、查看创建的主题列表
## 命令1无法执行 kafka-topics.bat --list --zookeeper localhost:2181 ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --list 3、启动生产者: kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
## 命令1无法执行 kafka-topics.bat --list --zookeeper localhost:2181 ## 命令2可以执行 kafka-topics.bat -bootstrap-server localhost:9092 --list 3、启动生产者:
3、启动生产者:
kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者: kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
kafka-console-producer.bat --broker-list localhost:9092 --topic kafka-test-topic 此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。 4、启动消费者:
此时可以从控制台输入信息,待消费者启动后可接收到生产者发布的消息。
4、启动消费者:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了 Windows下安装运行Kafka 在Windows下安装使用Kafka
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka-test-topic --from-beginning 此时便能看到发布出去的消息了
此时便能看到发布出去的消息了
Windows下安装运行Kafka 在Windows下安装使用Kafka