是否有一个kubectl命令来创建kafka主题而不使用import yaml file选项？

pxiryf3j 于 2021-06-04 发布在 Kafka

关注(0)|答案(3)|浏览(434)

我在Kubernetes部署了斯特里姆齐·Kafka，在我的地方也设置了库贝。但是每次我想在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

apache-kafka rancher kubernetes kubectl strimzi

来源：https://stackoverflow.com/questions/63559566/is-there-a-kubectl-command-to-create-kafka-topic-without-using-import-yaml-file

3条答案

按热度按时间

zc0qhyus1#

这是在kafka connect和kubectl的帮助下创建主题的命令之一

kubectl exec -it <kafka-connect-service-name>  -c <cluster-ip> -n labkafka -- kafka-topics --create --topic <topic_name> --bootstrap-server <bootstrap-server>

赞(0）回复(0）举报 2021-06-04

lb3vh1jj2#

另一种方法是使用 KafkaTopic 资源：

kubectl apply -f - <<EOF
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaTopic
metadata:
  name: my-new-topic
  labels:
    strimzi.io/cluster: my-cluster
spec:
  replicas: 3
  partitions: 10
EOF
``` `kubectl get kafkatopics.kafka.strimzi.io` ```
NAME           CLUSTER      PARTITIONS   REPLICATION FACTOR
my-new-topic   my-cluster   10           3

赞(0）回复(0）举报 2021-06-04

pprl5pva3#

你可以跑 kafka-topics 就像你在生产和消费一样

kubectl run ... kafka-topics --create ...

赞(0）回复(0）举报 2021-06-04

我来回答

是否有一个kubectl命令来创建kafka主题而不使用import yaml file选项？

3条答案

相关问题

热门标签

最新问答