kafka的下载与安装
下载
首先去官网下载 http://kafka.apache.org/downloads
选择最新的版本
下载完成后解压
使用tar -zxvf kafka_2.12-2.3.1.tgz 命令解压
然后进入kafka根目录下可以看到
修改配置文件
进入config/server.properties文件修改 broker.id和log.dirs
因为kafka一般是集群部署，所有每个单机有个broker.id，因为这里我只部一个单机测试，所有指定为1就可以了
log.dirs指定kafka的日志目录
启动zookeeper（这里用kafka自带的zk，也可以自己搭建）
用命令看是否启动成功（jps是jdk自带的命令，可以查看java进程）
这个QuorumPeerMain就是zk启动成功
启动kafka
创建一个topic
这里指定了zookeeper的地址，端口 副本个数为1（因为我只是单机一个broker） 分区数1 和topic名称test
查看topic是否创建成功
启动生产者
指定broker集群的端口 和具体的topic
启动消费者
指定broker集群的端口 和具体的topic --from-beginning代表从头开始读取消息
测试
用到的命令
| 命令 | 作用 |
|---|---|
| bin/zookeeper-server-start.sh -daemon config/zookeeper.properties | 启动zookeeper |
| bin/kafka-server-start.sh config/server.properties | 启动kafka服务器 |
| bin/kafka-topics.sh --create --zookeeper localhost:2181 --repication-factor 1 --partitions 1 --topic test | 创建topic |
| bin/kafka-topics.sh --list --zookeeper localhost:2181 | 查看topic列表 |
| bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test | 启动生产者 |
| bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning | 启动消费者 |