Kafka 基础命令操作
时间: 2024-05-16 21:11:23 浏览: 103
Kafka 是一个高吞吐量的分布式发布订阅消息系统,它主要用于处理实时数据流。下面是 Kafka 的一些基础命令操作:
1. 启动 Kafka 服务:通过命令行进入 Kafka 安装目录,执行如下命令启动 Kafka 服务:
```
bin/kafka-server-start.sh config/server.properties
```
2. 创建主题(Topic):通过如下命令创建一个名为 test 的主题:
```
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
```
3. 查看主题列表:通过如下命令查看当前 Kafka 中所有主题的列表:
```
bin/kafka-topics.sh --list --zookeeper localhost:2181
```
4. 发送消息:通过如下命令向主题 test 发送消息:
```
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
```
5. 消费消息:通过如下命令从主题 test 中消费消息:
```
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
```
以上是 Kafka 的一些基础命令操作,你可以在实践中更深入地了解 Kafka 的特性和操作方法。
阅读全文