Kafka 在 AWS 集群超时上创建主题

Question

我正在尝试连接到亚马逊托管的流式 kafka 集群。我一直在关注关于创建主题https://docs.aws.amazon.com/msk/latest/developerguide/create-topic.html的教程。

此集群的 VPC 安全组允许任何入站和出站流量，因此我不怀疑这会阻止连接。

我试过这个命令。

bin/kafka-topics.sh --create --zookeeper ZookeeperConnectString --replication-factor 3 --partitions 1 --topic AWSKafkaTutorialTopic

这会产生有问题的错误：

Exception in thread "main" kafka.zookeeper.ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING
    at kafka.zookeeper.ZooKeeperClient.$anonfun$waitUntilConnected$3(ZooKeeperClient.scala:242)
    at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
    at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:251)
    at kafka.zookeeper.ZooKeeperClient.waitUntilConnected(ZooKeeperClient.scala:238)
    at kafka.zookeeper.ZooKeeperClient.<init>(ZooKeeperClient.scala:96)
    at kafka.zk.KafkaZkClient$.apply(KafkaZkClient.scala:1825)
    at kafka.admin.TopicCommand$ZookeeperTopicService$.apply(TopicCommand.scala:262)
    at kafka.admin.TopicCommand$.main(TopicCommand.scala:53)
    at kafka.admin.TopicCommand.main(TopicCommand.scala)

我做错了什么，需要什么配置来防止连接超时？

Answer 1

我有同样的错误。一旦您的集群处于活动状态，请转到 MSK 服务并检查集群的安全组。然后，您必须在该安全组中添加入站规则，以允许来自客户端计算机安全组的所有流量。

这是教程的最后一点：

https://docs.aws.amazon.com/msk/latest/developerguide/create-client-machine.html