使用Docker安装Kafka

安装Kafka

本次安装kafka使用的docker镜像是wurstmeister/kafka - Docker Hub，安装流程如下。

准备docker-compose.yml文件：

version: '2'
services:
  zookeeper:
    image: zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: 192.168.1.102
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock

运行

docker-compose up -d

测试Kafka功能

使用kafkacat测试kafka是否安装成功，首先安装kafkacat:

sudo apt install kafkacat

开启kafka producer，命令行中随便输入一些字符：

$ kafkacat -P -b localhost -t mytopic
abcdefe

开启kafka consumer接收消息，控制台中收到消息如下，证明kafka正常启动运行。

$ kafkacat -b localhost -t mytopic
abcdefe