Kafka一些常用的命令行操作【包含主题命令、生产者和消费者命令】
文章目录
- 1、主题命令
- 2、生产者命令行操作
- 3、消费者命令行操作
1、主题命令
查看当前服务器中的所有 topic:
kafka-topics.sh --bootstrap-server node01:9092 --list
创建topic:
kafka-topics.sh --bootstrap-server node01:9092 --create --topic topicB --partitions 1 --replication-factor 3
查看主题的详情 :
kafka-topics.sh --bootstrap-server node01:9092 --describe --topic topicB
2、生产者命令行操作
向主题发送消息:
kafka-console-producer.sh --bootstrap-server node01:9092 --topic topicB
3、消费者命令行操作
接收主题最新消息:
kafka-console-consumer.sh --bootstrap-server node01:9092 --topic topicB
接收主题所有消息(包括历史消息):
kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic topicB