如何在使用strimzi运算符时列出Kafka主题

vyswwuz2  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(466)

嘿,我在用Kafka·斯特里姆齐。我使用以下yml文件创建了我的kafkatopic和kafkauser:

  1. apiVersion: kafka.strimzi.io/v1beta1
  2. kind: KafkaUser
  3. metadata:
  4. name: my-user
  5. labels:
  6. strimzi.io/cluster: my-cluster
  7. spec:
  8. authentication:
  9. type: tls
  10. authorization:
  11. type: simple
  12. acls:
  13. # Example consumer Acls for topic my-topic using consumer group my-group
  14. - resource:
  15. type: topic
  16. name: my-topic
  17. patternType: literal
  18. operation: Read
  19. host: "*"
  20. - resource:
  21. type: topic
  22. name: my-topic
  23. patternType: literal
  24. operation: Describe
  25. host: "*"
  26. - resource:
  27. type: group
  28. name: my-group
  29. patternType: literal
  30. operation: Read
  31. host: "*"
  32. # Example Producer Acls for topic my-topic
  33. - resource:
  34. type: topic
  35. name: my-topic
  36. patternType: literal
  37. operation: Write
  38. host: "*"
  39. - resource:
  40. type: topic
  41. name: my-topic
  42. patternType: literal
  43. operation: Create
  44. host: "*"
  45. - resource:
  46. type: topic
  47. name: my-topic
  48. patternType: literal
  49. operation: Describe
  50. host: "*"

  1. apiVersion: kafka.strimzi.io/v1beta1
  2. kind: KafkaTopic
  3. metadata:
  4. name: my-topic
  5. labels:
  6. strimzi.io/cluster: my-cluster
  7. spec:
  8. partitions: 1
  9. replicas: 1
  10. config:
  11. retention.ms: 7200000
  12. segment.bytes: 1073741824

[kafka@my-cluster-zookeeper-0 kafka]$bin/kafka-topics.sh--列表--zookeeper 10.101.97.123:2181
当我使用这个命令时,我得到了这个错误,我不知道如何修复它。

  1. Exception in thread "main" kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
  2. at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$3(ZooKeeperClient.scala:262)
  3. at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:258)
  4. at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:119)
  5. at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1865)
  6. at kafka.admin.TopicCommand$ZookeeperTopicService$.apply(TopicCommand.scala:360)
  7. at kafka.admin.TopicCommand$.main(TopicCommand.scala:55)
  8. at kafka.admin.TopicCommand.main(TopicCommand.scala)

在列出我的Kafka通片时遇到这个问题。请帮助我。

hlswsv35

hlswsv351#

您不能这样做,因为zookeeper连接是加密的,但您可以这样做,例如: kubectl exec -it my-cluster-kafka-0 -c kafka -- bin/kafka-topics.sh --bootstrap-server my-cluster-kafka-bootstrap:9092 --list 使用kafka服务器引导连接,而不是zookeeper。
当然,这是正确检查Kafka的方法,但您也可以使用以下方法检查相应的创建的Kafka主题资源: kubectl get kafkatopic

相关问题