2.1 安装部署

1、【单机部署】

1、下载并上传到nginx服务器
官网：http://kafka.apache.org/downloads.html

2、解压安装包

tar -zxvf kafka_2.12-3.0.0.tgz 

3、修改解压后的文件名称

 mv kafka_2.12-3.0.0/ kafka

4、进入到/mysoft/kafka/config 目录，修改配置文件

vim server.properties

本地做的修改主要是：
broker.id=1
delete.topic.enable=true
log.dirs=/mysoft/kafka/datas
zookeeper.connect=192.168.239.11:2181/kafka

配置文件各个配置意义：

5、启动单节点
先启动zookeeper 节点

启动kafka

./kafka-server-start.sh -daemon ../config/server.properties

6、查看kafka有没有正常启动： jps

7、配置kafka的环境变量
1）在/etc/profile.d/my_env.sh 文件中增加 kafka 环境变量配置

sudo vim /etc/profile.d/my_env.sh

增加如下内容

#KAFKA_HOME
export KAFKA_HOME=/mysoft/kafka
export PATH=$PATH:$KAFKA_HOME/bin

2）刷新一下环境变量。

 source /etc/profile

2、【集群部署】

之后进行补充

2.2 Kafka命令行操作

1、查看topic相关命令参数

bin/kafka-topics.sh

2、查看当前kafka服务器中的所有Topic

bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --list

3、创建 first topic

bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --create --partitions 1 --replication-factor 1 --topic first

4、查看 first 主题的详情

bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --describe --topic first

5、修改分区数（注意：分区数只能增加，不能减少）

bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --alter --topic first --partitions 3

6、删除 topic

 bin/kafka-topics.sh --bootstrap-server 192.168.239.11:9092 --delete --topic first

7、生产者发送消息

bin/kafka-console-producer.sh --bootstrap-server 192.168.239.11:9092 --topic first

8、消费者消费消息

消费 first 主题中的数据

bin/kafka-console-consumer.sh --bootstrap-server 192.168.239.11:9092 --topic first

把主题中所有的数据都读取出来（包括历史数据）。

bin/kafka-console-consumer.sh --bootstrap-server 192.168.239.11:9092 --topic first  --from-beginning