MENU

Catalog

    // //

    windows搭建Kafka

    August 23, 2024 • 技术分享

    修改任何配置文件时 如果原本文件中能找到,请替换内容即可

    以防止出现重复问题

    • 解压kafka压缩包。
    • 配置server.properties

    进入到config文件夹里面,找到server.properties文件,进行编辑,找到log.dirs,修改这个参数的路径为:log.dirs=D:\\kafka\\kafka_2.13-3.2.1\\kafka-logs (安装目录kefka-log)

    添加内容

    listeners=PLAINTEXT://:9092

    advertised.listeners=PLAINTEXT://127.0.0.1:9092 假如IP为127.0.0.1

    添加内容

    message.max.bytes=5242880
    #每个分区试图获取的消息字节数。要大于等于message.max.bytes
    replica.fetch.max.bytes=6291456
    #原有的socket.send.buffer.bytes,socket.receive.buffer.bytes,socket.request.max.bytes也要改成和message.max.bytes一样的大小

    以下为修改内容

    # The send buffer (SO_SNDBUF) used by the socket server
    socket.send.buffer.bytes=5242880
    # The receive buffer (SO_RCVBUF) used by the socket server
    socket.receive.buffer.bytes=5242880
    
    # The maximum size of a request that the socket server will accept (protection against OOM)
    socket.request.max.bytes=104857600
    • producer.properties 中添加

      #请求的最大大小为字节。要小于 message.max.bytes
      max.request.size = 5242880
    • consumer.properties 中添加

      #每个提取请求中为每个主题分区提取的消息字节数。要大于等于message.max.bytes
      fetch.message.max.bytes=6291456
    • 配置zookeeper.properties

    进入到config文件夹里面,找到server.properties文件,进行编辑,找到dataDir,修改这个参数的路径为:dataDir=D:\\kafka\\kafka_2.13-3.2.1\\zookeeper-data(安装目录zookeeper-data)

    • 启动zookeeper
    • 打开cmd,进入kafka安装目录,执行:
    • .\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
    • 启动kafka
    • 再打开一个cmd,进入kafka安装目录,执行:
    • .\bin\windows\kafka-server-start.bat .\config\server.properties
    • kafka和zooker正常启动之后,执行脚本createTopic.sh,创建topic
    • 等待topic创建结束,启动接收服务jar包
    Leave a Comment

    2 Comments
    1. 不错不错,我喜欢看 https://www.237fa.com/

    2. 想想你的文章写的特别好https://www.jiwenlaw.com/