ZooKeeper Modus

Apache ZooKeeper ist „ein zentraler Dienst zur Verwaltung von Konfigurationsinformationen, Benennung, Bereitstellung verteilter Synchronisation und Bereitstellung von Gruppendiensten. All diese Arten von Diensten werden in der einen oder anderen Form von verteilten Anwendungen verwendet“, einschließlich Apache Kafka.

Wenn Ihr Cluster den ZooKeeper Modus verwendet, können Sie die folgenden Schritte ausführen, um die ZooKeeper Apache-Verbindungszeichenfolge abzurufen. Wir empfehlen jedoch, dass Sie den verwenden, BootstrapServerString um eine Verbindung zu Ihrem Cluster herzustellen und Administratorvorgänge durchzuführen, da das --zookeeper Flag in Kafka 2.5 veraltet ist und aus Kafka 3.0 entfernt wurde.

Abrufen der Apache-Verbindungszeichenfolge mithilfe der ZooKeeper AWS Management Console

1. Öffnen Sie die MSK Amazon-Konsole unterhttps://console.aws.amazon.com/msk/.

2. Die Tabelle führt alle Cluster für die aktuelle Region unter diesem Konto auf. Wählen Sie den Namen eines Clusters aus, um dessen Beschreibung anzuzeigen.

3. Wählen Sie auf der Seite mit der Cluster-Zusammenfassung die Option Client-Informationen anzeigen. Hier werden Ihnen die Bootstrap-Broker sowie die ZooKeeper Apache-Verbindungszeichenfolge angezeigt.

Abrufen der ZooKeeper Apache-Verbindungszeichenfolge mithilfe der AWS CLI

1. Wenn Sie den Amazon-Ressourcennamen (ARN) Ihres Clusters nicht kennen, können Sie ihn finden, indem Sie alle Cluster in Ihrem Konto auflisten. Weitere Informationen finden Sie unter MSKAmazon-Cluster auflisten.

2. Um die ZooKeeper Apache-Verbindungszeichenfolge zusammen mit anderen Informationen zu Ihrem Cluster abzurufen, führen Sie den folgenden Befehl aus und ersetzen Sie ClusterArn mit dem ARN Ihres Clusters.

   aws kafka describe-cluster --cluster-arn ClusterArn

   Die Ausgabe dieses describe-cluster Befehls sieht wie das folgende JSON Beispiel aus.

   {
       "ClusterInfo": {
           "BrokerNodeGroupInfo": {
               "BrokerAZDistribution": "DEFAULT",
               "ClientSubnets": [
                   "subnet-0123456789abcdef0",
                   "subnet-2468013579abcdef1",
                   "subnet-1357902468abcdef2"
               ],
               "InstanceType": "kafka.m5.large",
               "StorageInfo": {
                   "EbsStorageInfo": {
                       "VolumeSize": 1000
                   }
               }
           },
           "ClusterArn": "arn:aws:kafka:us-east-1:111122223333:cluster/testcluster/12345678-abcd-4567-2345-abcdef123456-2",
           "ClusterName": "testcluster",
           "CreationTime": "2018-12-02T17:38:36.75Z",
           "CurrentBrokerSoftwareInfo": {
               "KafkaVersion": "2.2.1"
           },
           "CurrentVersion": "K13V1IB3VIYZZH",
           "EncryptionInfo": {
               "EncryptionAtRest": {
                   "DataVolumeKMSKeyId": "arn:aws:kms:us-east-1:555555555555:key/12345678-abcd-2345-ef01-abcdef123456"
               }
           },
           "EnhancedMonitoring": "DEFAULT",
           "NumberOfBrokerNodes": 3,
           "State": "ACTIVE",
           "ZookeeperConnectString": "10.0.1.101:2018,10.0.2.101:2018,10.0.3.101:2018"
       }
   }

   Das vorherige JSON Beispiel zeigt den ZookeeperConnectString Schlüssel in der Ausgabe des describe-cluster Befehls. Kopieren Sie den Wert, der diesem Schlüssel entspricht, und speichern Sie ihn, für den Fall, dass Sie ein Thema in Ihrem Cluster erstellen müssen.

   Wichtig

   Ihr MSK Amazon-Cluster muss sich in dem ACTIVE Status befinden, in dem Sie die ZooKeeper Apache-Verbindungszeichenfolge abrufen können. Wenn ein Cluster noch den Status „CREATING“ aufweist, enthält die Ausgabe des describe-cluster-Befehls „ZookeeperConnectString“ nicht. Warten Sie in diesem Fall einige Minuten und führen Sie den describe-cluster erneut aus, nachdem der Cluster den Status „ACTIVE“ erreicht hat.

Abrufen der ZooKeeper Apache-Verbindungszeichenfolge mit dem API

Informationen zum Abrufen der ZooKeeper Apache-Verbindungszeichenfolge mithilfe von finden Sie unter DescribeCluster. API