安装部署

集群规划：不是所有的服务器都需要安装某个软件，所以一定要做集群规划

脚本介绍

kafka-topics.sh

增

// 创建topic
bin/kafka-topics.sh --bootstrap-server hadoop100:9092 --topic first -create --partitions 1 --replication-factor 3
// 查看信息
bin/kafka-topics.sh --bootstrap-server hadoop100:9092 --list
// 查看详细信息
bin/kafka-topics.sh --bootstrap-server hadoop100:9092 --topic first --describe

删

--delete

改

1. 分区只能增加，不能减少
2. 命令行的形式不能修改副本

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

查

--list
// 详细信息
--describe

指定分区

--partitions

指定副本

--replication-factor

kafka-console-producer.sh

//打开生产数据界面
bin/kafka-console-producer.sh --bootstrap-server hadoop100:9092 --topic first

kafka-console-consumer.sh

//消费数据
bin/kafka-console-consumer.sh --bootstrap-server hadoop100:9092 --topic first
// 消费历史数据 --from-beginning
bin/kafka-console-consumer.sh --bootstrap-server hadoop100:9092 --topic first --from-beginning