不停止kafka容器的情况下用脚本删除docker中kafka的topics
时间: 2023-08-23 16:56:33 浏览: 169
要在不停止Kafka容器的情况下删除Docker中的Kafka topics,您可以使用Kafka提供的命令行工具kafka-topics.sh。以下是一个示例脚本:
```bash
#!/bin/bash
# 设置Kafka容器名称和IP地址
kafka_container_name="<kafka_container_name>"
kafka_container_ip="<kafka_container_ip>"
# 设置Kafka topics列表
topics=(topic1 topic2 topic3)
# 循环删除每个topic
for topic in "${topics[@]}"
do
# 使用kafka-topics.sh工具删除topic
docker exec -it $kafka_container_name \
/bin/bash -c "/opt/kafka/bin/kafka-topics.sh --delete \
--bootstrap-server $kafka_container_ip:9092 \
--topic $topic"
done
```
请替换 `<kafka_container_name>` 为您的Kafka容器的名称,`<kafka_container_ip>` 为Kafka容器的IP地址,`topics` 列表中是您要删除的topics名称。
执行此脚本将循环遍历topics列表,并使用kafka-topics.sh工具在运行中的Kafka容器中删除每个topic。请确保脚本中的kafka-topics.sh路径与您的Kafka安装路径相匹配。
阅读全文