zoukankan      html  css  js  c++  java
  • Windos 安装配置 Kafka

    安装步骤

    步骤一:安装JDK环境

    按照这个教程安装设置: https://www.cnblogs.com/IT-Ramon/p/12017387.html

    步骤二:下载Zookeeper

    下载地址:https://archive.apache.org/dist/zookeeper/zookeeper-3.4.13/zookeeper-3.4.13.tar.gz

    步骤三:下载Kafka

    下载地址:http://kafka.apache.org/downloads

    一、配置Zookeeper

    1、解压并进入ZooKeeper目录,小编:C:Kafkazookeeper-3.4.13conf

    2、 将“zoo_sample.cfg”重命名为“zoo.cfg”

    3、 打开“zoo.cfg”找到并编辑dataDir=C:\Kafka\zookeeper-3.4.13\tmp

    4、添加系统变量:ZOOKEEPER_HOME=C:\Kafka\zookeeper-3.4.13(这个好像加不加都行)

    5、 编辑path系统变量,添加路径:%ZOOKEEPER_HOME%in

    6、在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181)

    7、在C:Kafkazookeeper-3.4.13in目录下打开新的cmd,输入"zkServer",运行Zookeeper

    8、命令行提示如下:说明本地Zookeeper启动成功

     注意:不要关了这个窗口

     二、配置Kafka

    1、解压并进入Kafka目录,小编:C:Kafkakafka_2.12-2.3.1

    2、进入config目录找到文件server.properties并打开

    3、找到并编辑log.dirs=C:Kafkakafka_2.12-2.3.1kafka-logs

    4、找到并编辑zookeeper.connect=localhost:2181

    5、Kafka会按照默认,在9092端口上运行,并链接zookeeper的默认端口:2181

    6、进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

    .inwindowskafka-server-start.bat .configserver.properties
    

     注意:不要关了这个窗口,启用Kafka前请确保ZooKeeper实例已经准备好并开始运行

    三、测试

    1、创建主题,进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

    .inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    

    注意:不要关了这个窗口

    查看主题输入:

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

     2、创建生产者,进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

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

    注意:不要关了这个窗口

    3、创建消费者,进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

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

     当你看到 “hello” 、 “hi” 字样就大功告成了,说明消费者收到了生产者发出的信息

  • 相关阅读:
    MHA
    主从复制
    模拟数据误删除并恢复
    mysql日志类型和备份mysqldump2
    springcloud-Hystrix图形化Dashboard搭建
    springcloud-Hystrix工作流程
    springcloud-Hystrix-服务熔断使用
    springcloud-Hystrix-服务熔断理论
    springcloud-Hystrix-降级fallback完善
    springcloud-Hystrix-降级fallback
  • 原文地址:https://www.cnblogs.com/IT-Ramon/p/12017745.html
Copyright © 2011-2022 走看看