• Mac使用brew搭建kafka集群


    1. 第一步:单机搭建

    单机搭建:
    安装完后,默认自动安装对应版本zookeeper

    brew install kafka
    
    • 1

    2.第二步:修改配置文件:

    配置3个Kafka
    第一个(使用默认配置)

    vi /opt/homebrew/etc/kafka/server.properties
    
    • 1

    第二个

    cp /opt/homebrew/etc/kafka/server.properties /opt/homebrew/etc/kafka/server-1.properties
    
    • 1

    第三个

    cp /opt/homebrew/etc/kafka/server.properties /opt/homebrew/etc/kafka/server-2.properties
    
    • 1

    第二个和第三个修改配置文件
    vi /opt/homebrew/etc/kafka/server-1.properties

        broker.id=1 
        listeners=PLAINTEXT://:9093 
        log.dir=/tmp/kafka-logs-1
    
    • 1
    • 2
    • 3

    vi /opt/homebrew/etc/kafka/server-1.properties

        broker.id=2 
        listeners=PLAINTEXT://:9094 
        log.dir=/tmp/kafka-logs-2
    
    • 1
    • 2
    • 3

    3.第三步:查看启动服务位置

    brew list kafka
    
    • 1

    在这里插入图片描述

    4.第四步:服务启动/关闭

    启动kafka之前必须启动zookeeper,上面已查出👆(步骤3)。

    先启动zookeeper

    /opt/homebrew/Cellar/kafka/3.3.1_1/bin/zookeeper-server-start /opt/homebrew/etc/kafka/zookeeper.properties &
    
    • 1

    再启动kafka

    /opt/homebrew/Cellar/kafka/3.3.1_1/bin/kafka-server-start /opt/homebrew/etc/kafka/server.properties &
    
    • 1
    /opt/homebrew/Cellar/kafka/3.3.1_1/bin/kafka-server-start /opt/homebrew/etc/kafka/server-1.properties &
    
    • 1
    /opt/homebrew/Cellar/kafka/3.3.1_1/bin/kafka-server-start /opt/homebrew/etc/kafka/server-2.properties &
    
    • 1

    关闭kafka

    /opt/homebrew/Cellar/kafka/3.3.1_1bin/kafka-server-stop
    
    • 1

    关闭zookeeper

    /opt/homebrew/Cellar/kafka/3.3.1_1/bin/zookeeper-server-stop
    
    • 1

    5.最后:查看启动

    查看端口命令
    lsof -i :9092
    
    根据进程名查看进程信息
    ps aux | grep zookeeper
    
    • 1
    • 2
    • 3
    • 4
    • 5

    不过有个问题,需要一直挂着终端,不然9093、9094端口自己会断掉。

  • 相关阅读:
    掌控变量(C语言变量初步详解)
    词法分析考试做题必备注意点!
    idea启用多个环境
    合并RAR分卷压缩包
    fanuc机器人IO分配报警信号分配无效
    c++八股day2-虚函数表和虚函数表指针的创建时机
    腾讯一面:Mybatis中 Dao接口和XML文件的SQL如何建立关联?
    k8s免费在线集群工具
    【各类选举机制】
    Oracle-数据库组件invalid问题处理
  • 原文地址:https://blog.csdn.net/weixin_43849543/article/details/134288362