zoukankan      html  css  js  c++  java
  • 基础2-安装kafka

    前提条件:

    windows 10

    安装JDK

    已经安装并成功运行zookeeper

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

    选择二进制版本

    一、运行kafka

    解压到 D:kafka2.7 目录,注:目录不要有空格,在JAVA下空格有问题

    在目录 D:kafka2.7config 下找到文件 server.properties 

    修改默认配置为 log.dirs=D:kafkalog ,原有默认的配置是linux的地址,要改为windows地址

    CMD命令进入 D:kafka2.7 ,并运行命令 .inwindowskafka-server-start.bat .configserver.properties 

    显示如下界面

    二、创建kafka的消息topics

    进入目录 inwindows ,并执行命令

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

    三、发布者

    进入目录 inwindows ,并执行命令

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

    界面:

    四、接收者

    进入目录 inwindows ,并执行命令

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

    界面:

  • 相关阅读:
    C
    B
    A
    poj1222
    请求转发和重定向
    中文乱码
    Servlet 第一天
    Oracle 锁
    Oracle 包的学习
    初学Linux
  • 原文地址:https://www.cnblogs.com/myfqm/p/14340983.html
Copyright © 2011-2022 走看看