1、配置启动文件

// 首先 cd 到kafka的 config 目录
vim server.properties
// 找到 listeners 配置项，如果注释掉了，就删除注释
listeners=PLAINTEXT://127.0.0.1.9092
// 修改日志文件的位置,这个文件夹需要你自己创建
log.dirs=/usr/local/kafka/kafka-logs
// 修改连接 zookeeper 的地址, ip 写zookeeper所在的主机 ip
zookeeper.connet=127.0.0.1:2181

2、启动kafka

// 前提是你已经安装，配置过启动文件,切换到kafka的bin目录下
./kafka-server-start.sh -daemon ../config/server.properties

3、创建topic

kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic mytest

4、创建生产者

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic mytest

5、创建消费者

// 最好是使用两个连接客户端分别创建生产者和消费者
./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic mytest --consumer-property group.id=group_mytest

创建好生产者与消费者后，试一试能不能成功发生消息和接收消息。