创建主题
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
可以看到历史发送的数据不会接收