zoukankan      html  css  js  c++  java
  • wsl下安装并运行Kafka

    0.引言

    kafka是一个高性能分布式的MQ,今天我们就来玩玩

    1.安装

    wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz
    

    这是下载完的样子:

    tar -zxvf kafka_2.11-2.3.0.tgz
    cd kafka_2.11-2.3.0/  
    

    修改 kafka-server 的配置文件

    cd config
    vi server.properties 
    

    打开后如下所示

    将这俩位置改一下


    到此安装结束


    2.启动

    bin/zookeeper-server-start.sh -daemon config/zookeeper.properties #启动zookeeper
    bin/kafka-server-start.sh  config/server.properties #启动kafka
    

    成功启动
    使用 kafka-topics.sh 创建单分区单副本的 topic test:

    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    bin/kafka-topics.sh --list --zookeeper localhost:2181 #查看列表
    


    3.产生消息

    使用kafka-console-producer.sh 发送消息

    使用kafka-console-consumer.sh 接收消息

    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning 
    

    至此完成Kafka单机配置

  • 相关阅读:
    奇技淫巧训练之一
    基于JS模块化现状谈谈选择ES6模块的原因
    vue-cli3项目搭建配置以及性能优化
    Umi + DvaJS
    ReactFragment用法介绍
    什么是纯函数
    10.25考试
    10.23考试
    线段树合并(雨天的尾巴 题解)
    10.21考试
  • 原文地址:https://www.cnblogs.com/godoforange/p/11533599.html
Copyright © 2011-2022 走看看