zoukankan      html  css  js  c++  java
  • windows 环境使用 kafka

    近来学习 kafka,网上搜的教程好多不好用。在此开一贴记录一下学习过程。推荐官网,是最好的教程 http://kafka.apache.org/quickstart

    官网上是linux 环境,我用的是windows 环境。已经安装过jdk

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

     2 解压,我把它解压到 D:serverkafka2.12,路径中最好不要有空格

    3 修改配置文件 config 目录下的 zookeeper.properties 和 server.properties,

    3.1 zookeeper.properties 配置文件修改数据存储目录

    dataDir=D:/server/kafka2.12/zookeeper-logs

    3.2 server.properties 修改数据存储目录

    log.dirs=D:/server/kafka2.12/kafka-logs

    在解压目录下,执行以下命令。目录里有 bin 目录

    3.3 启动 zookeeper 服务

    binwindowszookeeper-server-start.bat configzookeeper.properties

    3.4 启动 kafka 服务

    binwindowskafka-server-start.bat configserver.properties

    4 创建一个主题

    binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

     5 使用如下命令查看创建的主题列表:

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

    6 启动生产者:

    binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test1

    启动consumer:

    binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test1 --from-beginning

    8 进行测试

     在 producer 终端输入字符串,在 consumer 终端可以看到所有的输入

  • 相关阅读:
    ES6-->ECMAScript 6.0 新增方法,一些基本语法
    初识 Nodejs (了解Nodejs)
    Vue框架初识
    python语法入门之流程控制
    python中基本运算符
    格式化输出
    基本数据类型
    变量,解释器,垃圾回收机制,小整数池总结
    编程语言发展史
    计算机基础
  • 原文地址:https://www.cnblogs.com/zhaopengcheng/p/9824546.html
Copyright © 2011-2022 走看看