ZooKeeper modus

Apache ZooKeeper adalah layanan terpusat untuk memelihara informasi konfigurasi, penamaan, menyediakan sinkronisasi terdistribusi, dan menyediakan layanan grup. Semua jenis layanan ini digunakan dalam beberapa bentuk atau lainnya oleh aplikasi terdistribusi,” termasuk Apache Kafka.

Jika cluster Anda menggunakan ZooKeeper mode, Anda dapat menggunakan langkah-langkah di bawah ini untuk mendapatkan string ZooKeeper koneksi Apache. Namun, kami menyarankan Anda menggunakan BootstrapServerString untuk terhubung ke operasi admin cluster dan perfom Anda karena --zookeeper bendera telah tidak digunakan lagi di Kafka 2.5 dan dihapus dari Kafka 3.0.

Mendapatkan string ZooKeeper koneksi Apache menggunakan AWS Management Console

1. Buka MSK konsol Amazon dihttps://console.aws.amazon.com/msk/.

2. Tabel menunjukkan semua cluster untuk wilayah saat ini di bawah akun ini. Pilih nama cluster untuk melihat deskripsinya.

3. Pada halaman ringkasan Cluster, pilih Lihat informasi klien. Ini menunjukkan kepada Anda broker bootstrap, serta string ZooKeeper koneksi Apache.

Mendapatkan string ZooKeeper koneksi Apache menggunakan AWS CLI

1. Jika Anda tidak mengetahui Amazon Resource Name (ARN) dari cluster Anda, Anda dapat menemukannya dengan mencantumkan semua cluster di akun Anda. Untuk informasi selengkapnya, lihat Daftar MSK kluster Amazon.

2. Untuk mendapatkan string ZooKeeper koneksi Apache, bersama dengan informasi lain tentang cluster Anda, jalankan perintah berikut, ganti ClusterArn dengan ARN cluster Anda.

   aws kafka describe-cluster --cluster-arn ClusterArn

   Output dari describe-cluster perintah ini terlihat seperti JSON contoh berikut.

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

   JSONContoh sebelumnya menunjukkan ZookeeperConnectString kunci dalam output describe-cluster perintah. Salin nilai yang sesuai dengan kunci ini dan simpan saat Anda perlu membuat topik di cluster Anda.

   penting

   MSKCluster Amazon Anda harus dalam ACTIVE keadaan agar Anda dapat memperoleh string ZooKeeper koneksi Apache. Ketika sebuah cluster masih dalam CREATING status, output dari describe-cluster perintah tidak termasukZookeeperConnectString. Jika ini masalahnya, tunggu beberapa menit dan kemudian jalankan describe-cluster lagi setelah cluster Anda mencapai ACTIVE status.

Mendapatkan string ZooKeeper koneksi Apache menggunakan API

Untuk mendapatkan string ZooKeeper koneksi Apache menggunakanAPI, lihat DescribeCluster.