zoukankan      html  css  js  c++  java
  • Kafka的下载安装和测试,及消费端数据中文乱码问题

    一、安装

    1.需要jdk

    2.需要zookeeper,这个东西在最新版的Kafka中内置。

    3.下载Kafka安装包

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

     

     注意:src结尾的时未编译项目(一般不下这个),下已编译项目Binary downloads这个

    下载最新版本。随便找一个舒服的目录解压。

    我解压到本电脑的D:DocumentsDownloads目录。

    二、运行zookeeper

    cd到解压的Kafka的文件位置。

    启动zookeeper(这个zookeeper是kafka内置的,新版本都是内置的,旧版本需下载一个zookepper)

    binwindowszookeeper-server-start.bat configzookeeper.properties

    运行结果:不报error就是成功了

     

    三、运行kafka

    cd到解压的Kafka的文件位置。我的是D:DocumentsDownloadskafka_2.12-2.2.0 执行下面的命令

    binwindowskafka-server-start.bat configserver.properties

    运行结果:

     

    四、简单使用

    创建主题topic,topic = demo

    binwindowskafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic demo

    -- 查看创建的topic

    binwindowskafka-topics.bat --list --bootstrap-server localhost:9092

      启动生产者 producer

    binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic demo

    启动生产者之后进入编辑页面,发送了 "nihao",

    启动消费者 customer

    binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic demo --from-beginning

    当消费者启动之后,收到了之前生产者发送的 “nihao”。

    注意:消费端数据中文乱码问题

    解决:CHCP 65001

    原因:kafka默认编码是utf-8,但win10是gbk,所以中文乱码,仅需在cmd下设置本机局部编码格式位utf-8即可解决(CHCP 65001)

  • 相关阅读:
    算法训练 区间k大数查询
    算法训练 最大最小公倍数
    身份证号码升级
    python包与模块导入
    python函数
    HDU 3595 博弈论,被支配的恐惧
    BZOJ 3195 [Jxoi2012]奇怪的道路
    大暑假集训
    [Poi2010]Monotonicity 2
    BZOJ 4868 HEOI 期末考试
  • 原文地址:https://www.cnblogs.com/CL-King/p/14456866.html
Copyright © 2011-2022 走看看