zoukankan      html  css  js  c++  java
  • Windows下安装kafka

    一、JDK安装

    二、ZK安装

    三、kafka安装

    kafka是基于jdk和zk上运行的,安装kafka前必须安装jdk和zk。

    • Kafka下载路径 http://kafka.apache.org/downloads

    • 解压文件(我的目录是E:softwarekafka_2.12-2.3.0 【这里不要在Program Files等文件名之间有空格的目录下,不然一会执行会不识别路径】)

    • 打开目录E:softwarekafka_2.12-2.3.0config下server.properties文件,把log.dirs修改为【log.dirs=E:softwarekafka_2.12-2.3.0kafka-logs】,也可以直接在

    • 进入kafka文件目录D:kafka_2.12-0.11.0.0,执行以下命令,启动kafka通讯的服务器broker

      .inwindowskafka-server-start.bat .configserver.properties
      
    • 进入kafka文件目录inwindows,创建kafka的消息topics

    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testDemo
    
    • 分别打开两个cmd窗口,进入目录D:kafka_2.12-0.11.0.0inwindows,创建Producer和Consumer

    (1)Producer

    进入目录D:kafka_2.12-0.11.0.0inwindows输入如下命令

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

    (2)Consumer

    进入目录D:kafka_2.12-0.11.0.0inwindows输入如下命令

    老版本命令

    kafka-console-consumer.bat --zookeeper localhost:2181 --topic testDemo
    

    如果上述命令报错:zookeeper is not a recognized option,z这是因为新版本删除直接绑定zk的命令,这运行新命令,绑定kafka服务

    kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testDemo
    

    四、可视化工具 kafka Tool

    下载地址http://www.kafkatool.com/download.html

    安装后进入配置


    用工具就可以监控kafka的各种信息了,nice

    参考

    https://www.cnblogs.com/mh-study/p/9537970.html

  • 相关阅读:
    celery 大量消息的分布式系统 定时任务
    小程序开发-生活娱乐两不误
    linux安装selenium+chrome+phantomjs
    CENTOS 7 安装 TINYPROXY 代理服务器
    JVM(三) 垃圾回收时间点和垃圾收集器
    JDK12 concurrenthashmap源码阅读
    JVM(二) 对象存活判断和垃圾回收算法
    java 线程池(2)
    JVM(一)
    java 线程池(1)
  • 原文地址:https://www.cnblogs.com/yz-yang/p/11733502.html
Copyright © 2011-2022 走看看