ZooKeeper modo - Amazon Managed Streaming for Apache Kafka

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

ZooKeeper modo

O Apache ZooKeeper é “um serviço centralizado para manter informações de configuração, nomear, fornecer sincronização distribuída e fornecer serviços de grupo. Todos esses tipos de serviços são usados de uma forma ou de outra por aplicativos distribuídos”, incluindo o Apache Kafka.

Se seu cluster estiver usando o ZooKeeper modo, você pode usar as etapas abaixo para obter a string de ZooKeeper conexão do Apache. No entanto, recomendamos que você use o BootstrapServerString para se conectar ao seu cluster e realizar operações administrativas, pois o --zookeeper sinalizador foi descontinuado no Kafka 2.5 e foi removido do Kafka 3.0.

Obtendo a string de ZooKeeper conexão do Apache usando o AWS Management Console

  1. Abra o MSK console da Amazon emhttps://console.aws.amazon.com/msk/.

  2. A tabela mostra todos os clusters da região atual nesta conta. Escolha o nome de um cluster para visualizar sua descrição.

  3. Na página Resumo do cluster, escolha Exibir informações do cliente. Isso mostra os corretores de bootstrap, bem como a string de conexão do Apache ZooKeeper .

Obtendo a string de ZooKeeper conexão do Apache usando o AWS CLI

  1. Se você não sabe o Amazon Resource Name (ARN) do seu cluster, você pode encontrá-lo listando todos os clusters em sua conta. Para obter mais informações, consulte Listando MSK clusters da Amazon.

  2. Para obter a string de ZooKeeper conexão do Apache, junto com outras informações sobre seu cluster, execute o comando a seguir, substituindo ClusterArn com o ARN do seu cluster.

    aws kafka describe-cluster --cluster-arn ClusterArn

    A saída desse describe-cluster comando se parece com o JSON exemplo a seguir.

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

    O JSON exemplo anterior mostra a ZookeeperConnectString chave na saída do describe-cluster comando. Copie o valor correspondente a essa chave e salve-o para quando precisar criar um tópico no cluster.

    Importante

    Seu MSK cluster Amazon deve estar no ACTIVE estado para que você possa obter a string de ZooKeeper conexão Apache. Quando um cluster ainda está no estado CREATING, a saída do comando describe-cluster não inclui a ZookeeperConnectString. Se esse for o caso, aguarde alguns minutos e execute describe-cluster novamente após o cluster atingir o estado ACTIVE.

Obtendo a string de ZooKeeper conexão do Apache usando o API

Para obter a string de ZooKeeper conexão do Apache usando oAPI, consulte DescribeCluster.