一、基于docker安装kafka

进入虚拟机，需要安装kafka的目录下，如：
cd /usr/local/docker/MQ/kafka
vi docker-compose.yml
docker-compose 信息：

version: '3'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: 192.168.118.131(自己服务器ip)
      KAFKA_CREATE_TOPICS: "test:1:1"
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock

直接docker-compose up,下载完成后会进行启动。

二、下载kafka客户端(kafka-tool)连接kafka

下载与自己电脑对应版本的kafka-tool

kafka-tool下载地址

下载后直接安装即可。安装完成后进入界面如下:

输入kafka 连接信息进行连接：

连接成功后。

kafka-tool 数据格式修改

推送数据前修改推送数据格式配置：Cluster name连接下双击Topics，展开topic，找到目标topic。由于kafka tool默认是用十六进制传入，点击topic，选择Properties,Content Types下的Key和Message选择String，点击【update】-【refresh】，才能使用正常的string格式。