windows系统下kafka_2.12-2.0.0的安装配置

Step 1: 准备安装包并解压

  1. 下载kafka_2.12-2.0.0,下载地址http://kafka.apache.org/quickstart
  2. 配置zokeeper, 为何须要配置zokeeper,zokeeper和kafka的关系什么?如见https://blog.csdn.net/u011311291/article/details/85264046
  3. 解压kafka_2.12-2.2.0.tgz,下载包里面包括window和linux两种启动文件,见如图

Step 2: 启动kafka

  1. 上面讲到了Kafka用到了Zookeeper,全部首先启动Zookper,Zookper支持集群模式下启动, 咱们先用单点方式启动Zookkeeper服务。

进入kafka解压目录,执行bin\windows\zookeeper-server-start.bat config/zookeeper.properties命令, , 见到INFO binding to port 0.0.0.0/0.0.0.0:2181 (org.apache.zookeeper.server.NIOServerCnxnFactory)等字样,表示启动成功。linux


  1. 启动kafka 进入kafka解压目录,执行bin\windows\kafka-server-start.bat config/server.properties命令, , 见到如图的字眼表示成功

   

Step 3: 使用kafka

  1. topic操做 建立一个叫作“kafka1”的topic,它只有一个分区,一个副本. bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafka1
  2. 查看已建立的topic bin\windows\kafka-topics.bat -list --zookeeper localhost:2181
  3. 消息测试 Kafka 使用一个简单的命令行producer,从文件中或者从标准输入中读取消息并发送到服务端。默认的每条命令将发送一条消息。 运行producer并在控制台中输一些消息,这些消息将被发送到服务端,发送消息时需带上topic,因接受消息的时也是监听topic的: bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kafka1 启动consumer接受消息 bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafka1 --from-beginning

基础的安装已完成了,固然后续还有对broker的集群操做等,这里先讲到这里。apache

相关文章
相关标签/搜索