ZooKeeper modo - Amazon Managed Streaming for Apache Kafka
Obtendo a string de ZooKeeper conexão do Apache usando o AWS Management ConsoleObtendo a string de ZooKeeper conexão do Apache usando o AWS CLIObtendo a string de ZooKeeper conexão do Apache usando o API

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 Listar 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 do 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.