amazon-web-services - Kafka在AWS集群超时上创建主题
问题描述
我正在尝试连接到亚马逊托管的流式 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)
我做错了什么,需要什么配置来防止连接超时?
解决方案
我有同样的错误。一旦您的集群处于活动状态,请转到 MSK 服务并检查集群的安全组。然后,您必须在该安全组中添加入站规则,以允许来自客户端计算机安全组的所有流量。
这是教程的最后一点:
https://docs.aws.amazon.com/msk/latest/developerguide/create-client-machine.html
推荐阅读
- windows - Windows 10 C# 应用程序将无法运行说 CLRWrapper 缺少依赖项
- reactjs - React 16.4 基于 Promise 的条件渲染
- java - 为什么使用函数包装器捕获方法调用链的异常似乎比手动检查要昂贵得多?
- timer - 定时器溢出竞争条件
- java - 将 log4j jar 从 2.11.1 升级到 2.13.2 后 WAS9 JDK8 上的 IncompatibleClassChangeError
- python - Is there any way that I can get a full BeautifulSoup element?
- html - 我可以让图像表现得好像它有不同的高度(不同的尺寸)吗?
- javascript - c#中等效的jquery location.pathname
- php - Laravel 或在哪里加入
- python - 如何根据索引、列名和单元格本身为每个单元格运行一个函数?