Kafka基本命令行使用指南
Kafka是一种开源分布式流处理平台,常用于处理大规模的数据流。以下是Kafka常用的基本命令行:
1. 创建topic:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2. 发送消息到topic:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
3. 从topic消费消息:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
4. 查看topic列表:
bin/kafka-topics.sh --list --zookeeper localhost:2181
5. 查看topic详情:
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test
以上是Kafka基本命令行的使用指南,希望对你有所帮助。
用户评论