Apache ошибка экземпляра kafka и кластера msk - PullRequest
Новая
       1

Apache ошибка экземпляра kafka и кластера msk

0 голосов
/ 22 апреля 2020

Я пытаюсь установить sh соединение между aws msk и экземпляром ec2 (aws linux). Мне удалось запустить zookeeper и kafka, но я не смог опубликовать sh любую топи c и установить sh соединение между кластером msk и экземпляром ec2. Я правильно выполнил все шаги из документации Amazon, сохранил кластер и ec2 в той же группе безопасности vp c и ec2, что и входящее правило в vp c, но я не могу подключиться и всегда заканчиваюсь этой ошибкой 

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)
...