kafka 删除topic中的数据 shell命令是什么
时间: 2023-03-12 17:09:48 浏览: 124
Kafka 的shell命令用于删除topic中的数据是 `bin/kafka-topics.sh --zookeeper <zookeeper hostname>:<port> --delete --topic <topicname>`.
相关问题
kafka创建topic的命令
Kafka创建topic的命令通常使用kafka-topics.sh脚本来完成。一个常用的创建topic的命令如下所示:
```shell
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 3 --bootstrap-server localhost:9092
```
这条命令会创建一个名为test的topic,设置3个分区,每个分区需分配3个副本。在执行这条命令之后,Kafka会返回"Created topic 'test'"的消息,表示topic创建成功。需要注意的是,这只是创建topic的第一步,后续还有其他步骤要完成,包括controller的工作等。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *3* [kafka是如何创建topic的](https://blog.csdn.net/Maxiao1204/article/details/120753126)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
- *2* [kafka使用命令.txt](https://download.csdn.net/download/weixin_35085215/12504208)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]
kafka shell 创建topic
好的,以下是使用 Kafka Shell 创建 topic 的步骤:
1. 打开终端并进入 Kafka 安装目录。
2. 执行以下命令,创建一个名为 `my_topic` 的 topic(请根据实际需求修改 topic 名称):
```
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my_topic
```
解释:
- `--create`:表示创建 topic。
- `--zookeeper`:指定 ZooKeeper 的地址和端口号。
- `--replication-factor`:指定 topic 的副本数。
- `--partitions`:指定 topic 的分区数。
- `--topic`:指定要创建的 topic 名称。
3. 执行以下命令,验证 topic 是否创建成功:
```
bin/kafka-topics.sh --list --zookeeper localhost:2181
```
解释:
- `--list`:表示列出所有 topic。
如果 `my_topic` 出现在输出结果中,则表示创建成功。
阅读全文