Kafka 生产者消费者命令行操作
生产者命令行操作
查看操作生产者命令参数
bin/kafka-console-producer.sh
| 参数 | 描述 |
| --bootstrap-server | 连接的 Kafka Broker 主机名称和端口号。 |
| --topic | 操作的 topic 名称。 |
发送消息
bin/kafka-console-producer.sh --bootstrap-server hadoop102:9092 --topic first
消费者命令行操作
查看操作消费者命令参数
bin/kafka-console-consumer.sh
| 参数 | 描述 |
| --bootstrap-server | 连接的 Kafka Broker 主机名称和端口号。 |
| --topic | 操作的 topic 名称 |
| --from-beginning | 从头开始消费。 |
| --group | 指定消费者组名称。 |
消费 first 主题中的数据
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic first
把主题中所有的数据都读取出来（包括历史数据）
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --from-beginning --topic first