ZooKeeper mode - Amazon Managed Streaming for Apache Kafka

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

ZooKeeper mode

Apache ZooKeeper est « un service centralisé permettant de gérer les informations de configuration, de nommer, de fournir une synchronisation distribuée et de fournir des services de groupe. Tous ces types de services sont utilisés sous une forme ou une autre par des applications distribuées », notamment Apache Kafka.

Si votre cluster utilise le ZooKeeper mode, vous pouvez suivre les étapes ci-dessous pour obtenir la chaîne de ZooKeeper connexion Apache. Cependant, nous vous recommandons d'utiliser le BootstrapServerString pour vous connecter à votre cluster et effectuer des opérations d'administration, car l'--zookeeperindicateur est obsolète dans Kafka 2.5 et a été supprimé dans Kafka 3.0.

Obtenir la chaîne de ZooKeeper connexion Apache à l'aide du AWS Management Console

  1. Ouvrez la MSK console Amazon à l'adressehttps://console.aws.amazon.com/msk/.

  2. Le tableau présente tous les clusters de la région actuelle sous ce compte. Choisissez le nom d'un cluster pour afficher sa description.

  3. Sur la page de résumé du cluster, choisissez Voir les informations client. Cela vous montre les courtiers bootstrap, ainsi que la chaîne de ZooKeeper connexion Apache.

Obtenir la chaîne de ZooKeeper connexion Apache à l'aide du AWS CLI

  1. Si vous ne connaissez pas le nom de ressource Amazon (ARN) de votre cluster, vous pouvez le trouver en répertoriant tous les clusters de votre compte. Pour de plus amples informations, veuillez consulter Répertorier les MSK clusters Amazon.

  2. Pour obtenir la chaîne de ZooKeeper connexion Apache, ainsi que d'autres informations sur votre cluster, exécutez la commande suivante, en remplaçant ClusterArn avec le ARN de votre cluster.

    aws kafka describe-cluster --cluster-arn ClusterArn

    Le résultat de cette describe-cluster commande ressemble à l'JSONexemple suivant.

    { "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" } }

    L'JSONexemple précédent montre la ZookeeperConnectString clé dans le résultat de la describe-cluster commande. Copiez la valeur correspondant à cette clé et enregistrez-la pour pouvoir la réutiliser lorsque vous devrez créer une rubrique sur votre cluster.

    Important

    Votre MSK cluster Amazon doit être en bon ACTIVE état pour que vous puissiez obtenir la chaîne de ZooKeeper connexion Apache. Lorsqu'un cluster a toujours l'état CREATING, la sortie de la commande describe-cluster n'inclut pas ZookeeperConnectString. Si c'est le cas, attendez quelques minutes, puis exécutez à nouveau describe-cluster après que votre cluster a atteint l'état ACTIVE.

Obtenir la chaîne de ZooKeeper connexion Apache à l'aide du API

Pour obtenir la chaîne de ZooKeeper connexion Apache à l'aide duAPI, consultez DescribeCluster.