创建主题
kafka-topics.sh --bootstrap-server hadoop100:9092 --create --partitions 1 --replication-factor 3 --topic first

查看主题列表
kafka-topics.sh --bootstrap-server hadoop100:9092 --list

查看主题详情
kafka-topics.sh --bootstrap-server hadoop100:9092 --describe --topic first

修改分区数(只能增加,不能减少)
kafka-topics.sh --bootstrap-server hadoop100:9092 --alter --topic first --partitions 3

重新查看详情

创建生产者发送数据
kafka-console-producer.sh --bootstrap-server hadoop100:9092 --topic first

创建消费者,消费数据
把主题中所有的数据都读取出来(包括历史数据)。
kafka-console-consumer.sh --bootstrap-server hadoop100:9092 --from-beginning --topic first

kafka-console-consumer.sh --bootstrap-server hadoop100:9092 --topic firs
可以看到历史发送的数据不会接收





















