是否有 kubectl 命令可以在不使用 import yaml 文件选项的情况下创建 kafka 主题？

Question

我已经在 kubernetes 上部署了 strimzi kafka，并且在本地也安装了 kube。但每次我想要在 kafka 中创建一个新主题时，我都需要通过 rancher 导入 yaml 文件并提供主题名称来创建一个主题。

有没有办法直接通过 kubectl 命令创建 kafka 主题？

这些是我用来运行 kafka 的命令：

Producer: kubectl run kafka-producer1 -ti --image=strimzi/kafka:0.18.0-kafka-2.4.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --broker-list 11.23.41.32:31025 --topic topic-name

Consumer: kubectl run kafka-consumer1 -ti --image=strimzi/kafka:0.18.0-kafka-2.4.0 --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server 11.23.41.32:31025 --topic topic-name --from-beginning

Answer 1

通过命令行创建主题的步骤：（假设zookeeper在端口2181上运行，kafka服务器在9092上运行）

1. 使用此命令进入 kafka pod

kubectl exec -it kafka-pod-name -- /bin/bash

2. 使用以下命令创建主题

kafka-topics --bootstrap-server localhost:9092 --create --topic topic-name --replication-factor 1 --partitions 3

3. 您可以使用以下命令验证消息的生成和消耗 -

a) 生产-->

1. kafka-console-producer --broker-list localhost:9092 --topic <topic-you-created-before>
2. 提供一些消息

b) 消耗-->kafka-console-consumer --bootstrap-server localhost:9092 --topic audit --from-beginning

你可以在这里看到消息（由生产者提供）