Kafka 基础教程 — Mac搭建kafka环境

1、下载Kafka安装包

下载地址

    # 将压缩包移动到/usr/local/
    mv kafka_2.12-3.1.0.tgz /usr/local/
    
    # 解压
    tar -zxvf kafka_2.12-3.1.0.tgz

2、启动

启动zookeeper

    # 启动独立安装的zookeeper
    ./zkServer.sh start
    
    # 也可以自动kafka自带的zookerper
    ./zookeeper-server-start.sh ../config/zookeeper.properties

启动kafka

    cd /usr/local/kafka_2.12-3.1.0/bin
    
    ./kafka-server-start.sh -daemon ../config/server.properties

3、kafka交互

    # 创建一个topic
    ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test
    
    # 查看创建的topic
    ./kafka-topics.sh --bootstrap-server localhost:9092 --list

消息通信：

1. 启动kafka的服务端：

    ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test

1. 打开一个新的终端，进入kafka的bin目录，启动kafka的客户端：

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

1. 发送消息

   

此时客户端终端接收到消息：

4、关闭kafka

    # 关闭kafka
    ./kafka-server-stop.sh
    
    # 关闭zookeeper
    ./zkServer.sh stop

5、Web UI kafdrop

下载地址

在IDE工具中使用maven打成jar包

启动命令（脚本）：

    # startup.sh
    
    java --add-opens=java.base/sun.nio.ch=ALL-UNNAMED -jar target/kafdrop-<version>.jar --kafka.brokerConnect=<host:port,host:port>,...

    # restart.sh
    
    ps -ef | grep kafdrop-3.29.0.jar | grep -v grep | awk '{print $2}' | xargs kill -9
    rm -rf nohup.out
    nohup ./startup.sh > nohup.out &

访问9000端口即可。