**1. 创建topic** ```shell -- 查看有哪些参数 [root@hadoop101 kafka]# bin/kafka-topics.sh --create 要创建一个topic --topic 指定topic的名字 --zookeeper 指定要连接的zookeeper --replication-factor 设置副本因子，这个数值不能大于Broker数量, 即不能大于节点数 --partitions 分区数量 -- 创建topic [root@hadoop101 kafka]# bin/kafka-topics.sh --create --topic topic1 --zookeeper hadoop101:2181 --replication-factor 1 --partitions 3 Created topic "topic1". -- 查看当前服务器所有的topic [root@hadoop101 kafka]# bin/kafka-topics.sh --list --zookeeper hadoop101:2181 topic1 -- 查看topic的详细信息 [root@hadoop101 kafka]# bin/kafka-topics.sh --describe --zookeeper hadoop101:2181 Topic:topic1 PartitionCount:3 ReplicationFactor:1 Configs: Topic: topic1 Partition: 0 Leader: 0 Replicas: 0 Isr: 0 Topic: topic1 Partition: 1 Leader: 0 Replicas: 0 Isr: 0 Topic: topic1 Partition: 2 Leader: 0 Replicas: 0 Isr: 0 ``` **2. 生成和消费数据** ```shell -- 启动kafka生产者 [root@hadoop101 kafka]# bin/kafka-console-producer.sh --broker-list hadoop101:9092 --topic topic1 -- 启动kafka消费者 --from-beginning 代表从头消费 [root@hadoop101 kafka]# bin/kafka-console-consumer.sh --bootstrap-server hadoop101:9092 --topic topic1 --from-beginning -- 在生产者终端输入消息 >hello world kafka > -- 在消费者终端就可以看到消息了 hello world kafka ```