1.查看当前服务器中的所有topic
在Kafka目录下
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --list
2.创建topic
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 --create --replication-factor 2 --partitions 1 --topic first
bin/kafka-topics.sh --bootstrap-sercer hadoop102:9092 --create --topic first --partitions 3 --replication-factor 2
3.删除topic
bin/kafka-topics.sh --bootstrap-sercer hadoop102:9092 -delete --topic first
4.发送消息
bin/kafka-console-producer.sh --broker-list hadoop102:9092 --topic first
5.消费消息
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first
bin/kafka-console-consumer.sh --bootstrap-sercer hadoop102:9092 --from-begining --topic first
--from-begining:会把主题中现有的所有的数据都读取出来。
6.查看某个topic的详情
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 -describe --topic first
7.修改分区数(修改topic的配置 只能修改 分区数 而且只能往大的修改 不能往小的修改)
bin/kafka-topics.sh --bootstrap-server hadoop102:9092 -alter --topic first --partitions 3
