zoukankan      html  css  js  c++  java
  • Windows下安装单机Kafka

    Zookeeper

    解压后进入conf目录,复制出一个zoo.cfg,然后进入bin目录,直接运行zkServer.cmd

    Kafka

    首先你得有一个安装包:

    解压,目录结构:

    config目录里面是配置文件,在这里不做配置

     在根目录,路径的位置输入cmd,回车即可跳出命令行

    第一个坑

    输入:

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

    经上网查阅得知,先设置CLSAAPATH,SO--

    set classpath=.

    出现一大堆,就成功了。

    下面测试:先进入Windows目录搞出命令行,输入以下命令

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

     第二个坑

    还是老办法,先设置CLASSPATH。输入以下内容可以查看topic列表

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

    下一步,创建生产者,输入:

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

    下一步,打开一个新的命令行,输入以下内容

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

    现在,回到生产者的命令行,输入任意内容。你可以看见,当你回车之后,消费者自动收到你的消息

  • 相关阅读:
    SQL解发器与SQL游标实例
    动态调用JS
    HDU_5729_rmq+二分
    struts2 在MyEclipse中 的配置
    Struts 1.2 中如何测试Action
    OGNL使用小结【转】
    JUnit中assertEquals和assertSame方法的不同
    struts2 ActionContext
    ser文件与Java对象序列化
    测试Action组件代码(StrutsTestCase)
  • 原文地址:https://www.cnblogs.com/LUA123/p/9264147.html
Copyright © 2011-2022 走看看