下载

官方下载地址：Apache Kafka

==注意：需要检查支持的JDK版本==

wget https://dlcdn.apache.org/kafka/3.1.0/kafka_2.12-3.1.0.tgz

安装

  • 解压：tar -zxvf kafka_2.12-3.1.0.tgz

  • 修改zookeeper配置文件：zookeeper.properties

    • 端口：clientPort=2181

  • 修改kafka配置文件：

    • 服务端全局配置：server.properties

      • zookeeper.connect=localhost:2181

      • 允许外部连接 ：

        • listeners=PLAINTEXT://0.0.0.0:9092
        • advertised.listeners=PLAINTEXT://[ip]:9092
          • ==注意：== 这里配置的IP为外网IP；
    • producer.properties
      • bootstrap.servers=localhost:9092

启动

  • 后台启动zookeeper：bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
    • 检查配置的端口是否监听：lsof -i:xxx
    • 20220330092011.png
  • 后台启动Kafka：bin/kafka-server-start.sh -daemon config/server.properties
    • 20220330092742.png

测试是否正常

测试时最好不使用后台启动，方便快速重启

  • 生产者：bin/kafka-console-producer.sh --broker-list [ip]:[port] --topic test1
  • 消费者：bin/kafka-console-consumer.sh --bootstrap-server [ip]:[port] --topic test1

在生产端输入数据，消费端能够收到数据，即为成功。