Kafka安装、配置和使用

Kafka的安装配置与使用

1、下载安装包Apache Kafka

解压缩安装包

2、配置

bin目录：启动、操作Kafka命令存放位置、默认为liunx命令，windows文件夹下是windows命令

config：配置文件

a、在config文件夹下配置zookeeper管理集群的工具

打开zookeeper.properties

b、在config文件夹下配置server.properties

3、使用

a、命令行下进入kafka的安装路径下

b、执行命令去启动zookeeper

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

c、启动kafka-server

bin\windows\kafka-server-start.bat config\server.properties

报错

原因是启动了zookeeper之后我关闭了cmd命令行窗口，因此zookeeper也就关闭了，所以不能关闭上一步的cmd窗口，而是应该再打开一个窗口执行这次的启动命令

成功之后会再data下产生数据

d、使用kafka，需要再打开一个命令行

直接cd到bin\windows下

创建一个主题（消息的位置、类别）

命令：kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

创建成功

查看主题

以生产者身份向服务器发送消息

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

然后以消费者身份读取消息

生产者没产生一个消息，都会被消费者随之消费，在生产者输入框中输入，消费者输入框就会输出消息