03-Kafka命令行生产者发送消息和消费者消费消息实战

创建topic

./kafka-topics.sh --create --zookeeper 121.40.146.120:2181 --replication-factor 1 --partitions 2 --topic xdclass-topic

查看topic

./kafka-topics.sh --list --zookeeper 121.40.146.120:2181

生产者发送消息

./kafka-console-producer.sh --broker-list 121.40.146.120:9092  --topic xdclass-topic

消费者消费消息 ( --from-beginning：会把主题中以往所有的数据都读取出来, 重启后会有这个重复消费)

./kafka-console-consumer.sh --bootstrap-server 121.40.146.120:9092 --from-beginning --topic xdclass-topic

./kafka-console-consumer.sh --bootstrap-server 121.40.146.120:9092 --topic xdclass-topic

删除topic

./kafka-topics.sh --zookeeper 121.40.146.120:2181 --delete --topic xdclass-topic

查看broker节点topic状态信息

./kafka-topics.sh --describe --zookeeper 121.40.146.120:2181  --topic xdclass-topic