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单机配置

  • 相关阅读:
    微擎使用函数获取用户微信信息
    xshell连接不上linux情况一
    destoon手机端分页
    kvm安装win2012
    kvm安装ubuntu
    KVM的磁盘管理相关
    ubuntu的iptables
    kvm安装win2003
    Centos-6.4 安装mysql-5.5.14
    CentOS 6.4安装bind-9.8.2最新版(DNS服务器)
  • 原文地址:https://www.cnblogs.com/godoforange/p/11533599.html
Copyright © 2011-2022 走看看