zoukankan      html  css  js  c++  java
  • kafka在windows下安装单机版

    1、环境准备

    jdk8
    kafka_2.12-2.1.1(已包含了zookeeper,无需自行下载zk也无需安装)

    2、下载kafka,本文采用的是:Scala 2.12  - kafka_2.12-2.1.1.tgz (ascsha512),使用7zip或winrar解压即可。解压后目录如下:

     3、配置

    此处,注意是正斜杠(/),不要使用反斜杠()。

     4、启动

    1)、启动zk:在当前目录下打开dos窗口,并执行如下命令:

    zookeeper-server-start.bat ....configzookeeper.properties

    2)、启动kafka

    kafka-server-start.bat ....configserver.properties

    5、测试

    1)、创建主题

    kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic

    2)、查看创建的主题

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

    3)、启动生产者

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

    此时,可输入任意字符,等消费者启动后,就能收到了。

    4)、启动消费者

    kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic mytopic --from-beginning

  • 相关阅读:
    ubuntu系统安装初始化脚本
    21_多线程
    20_IO
    19_异常
    18_集合
    17_内部类和常用类
    16_接口
    15_abstract,static,final
    14_面向对象
    13_数组
  • 原文地址:https://www.cnblogs.com/yaoyuan2/p/12655984.html
Copyright © 2011-2022 走看看