zoukankan      html  css  js  c++  java
  • windows安装kafaka并且创建topci及发送消息

    步骤

    springboot简单集成kafka请看本人另外一篇文章springboot集成kafka基础入门

    1.安装JDK

    安装JAVA环境,这里不赘述,注意配置JAVA_HOME并确保安装成功

    2.下载kafka

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

    在这里插入图片描述

    选择红框中的版本,Kafka包名组成: Scala版本 - Kafka自身版本

    下官方推荐的版本

    解压之后

    在这里插入图片描述
    bin是可执行文件

    config是配置文件

    3.启动kafka

    打开binwindows目录,该目录下是所有windows命令:

    kafka自动zookeeper

    在这里插入图片描述
    我们需要的kafka启动脚本和zookeeper启动脚本

    打开命令行,执行命令zookeeper-server-start.bat ....configzookeeper.properties

    在这里插入图片描述

    运行成功,2181端口,不要关闭窗口

    再打开一个命令行,执行命令 kafka-server-start.bat ....configserver.properties

    在这里插入图片描述

    运行成功,不要关闭窗口

    4.测试

    创建一个主题

    命令行kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-topic

    创建了一个叫test-topic的topic

    查看创建的主题列表

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

    在这里插入图片描述

    启动生产者:

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

    启动之后 随便输入点消息

    在这里插入图片描述

    启动消费者:

    kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning
    在这里插入图片描述
    接收到消息

    在这里插入图片描述
    接收到消息

    以上就是下载并安装启动消费全过程

  • 相关阅读:
    BZOJ1006: [HNOI2008]神奇的国度
    弦图与区间图
    后缀自动机
    插头DP
    BZOJ3328: PYXFIB
    BZOJ2118: 墨墨的等式
    BZOJ3916: [Baltic2014]friends
    BZOJ1337: 最小圆覆盖
    BZOJ3784: 树上的路径
    代码模版
  • 原文地址:https://www.cnblogs.com/hellohero55/p/14389645.html
Copyright © 2011-2022 走看看