一、准备压缩包文件

kafka_2.12-3.0.0.tgz
其中 2.13 为Scala的版本， 3.0 为 kafika 的版本

二、解压缩并修改配置文件

1. 编辑 config目录下的 server.properties 文件

vim server.properties

2. 具体修改配置

1.修改监听地址为本地
listeners=PLAINTEXT://192.168.61.128:9092

2.修改监听地址
advertised.listeners=PLAINTEXT://192.168.61.128:9092

3. log数据地址
log.dirs=/tmp/kafka-logs

4.zokeeper 连接地址，默认为本地单机连接，若为集群参考下例
# server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
zookeeper.connect=localhost:2181

三、常用启停命令

1、启动，最后的 & 意为后台启动
bin/kafka-server-start.sh config/server.properties &

2、停止
bin/kafka-server-stop.sh

3、创建 test Topic 
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-topic

4、查看已经创建的Topic信息
bin/kafka-topics.sh --list --zookeeper localhost:2181

5、发送消息
bin/kafka-console-producer.sh --broker-list 192.168.61.128:9092 --topic test-topic

6、接收消息
bin/kafka-console-consumer.sh --bootstrap-server 192.168.61.128:9092 --topic test-topic --from-beginning