Lihat informasi partisi menggunakan AWS CLI - Amazon Managed Streaming untuk Apache Kafka
Memahami informasi partisiHasil paginatingKasus penggunaan umum

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Lihat informasi partisi menggunakan AWS CLI

Jalankan perintah berikut, ganti ClusterArn dengan Amazon Resource Name (ARN) cluster Anda dan TopicName dengan nama topik.

aws kafka describe-topic-partitions --cluster-arn ClusterArn --topic-name TopicName

Output dari perintah ini terlihat seperti contoh JSON berikut.

{
    "partitions": [
        {
            "partition": 0,
            "leader": 1,
            "replicas": [1, 2, 3],
            "isr": [1, 2, 3]
        },
        {
            "partition": 1,
            "leader": 2,
            "replicas": [2, 3, 1],
            "isr": [2, 3, 1]
        },
        {
            "partition": 2,
            "leader": 3,
            "replicas": [3, 1, 2],
            "isr": [3, 1]
        }
    ]
}

Memahami informasi partisi

Tanggapan tersebut mencakup informasi berikut untuk setiap partisi:

  • partisi — Nomor partisi. Partisi diberi nomor mulai dari 0.

  • leader — ID broker pemimpin untuk partisi ini. Pemimpin menangani semua permintaan baca dan tulis untuk partisi.

  • replika — Daftar broker IDs yang memiliki replika partisi ini. Ini termasuk in-sync dan out-of-sync replika.

  • isr — Daftar broker IDs yang merupakan replika sinkron. Replika ini sepenuhnya terjebak dengan pemimpin dan dapat mengambil alih sebagai pemimpin jika diperlukan.

Pada contoh di atas, partisi 2 memiliki out-of-sync replika. replicasDaftar ini termasuk broker 2, tetapi isr daftarnya tidak. Ini menunjukkan bahwa broker 2 tidak sepenuhnya terjebak dengan pemimpin untuk partisi ini.

Hasil paginating

Jika topik Anda memiliki banyak partisi, Anda dapat menggunakan pagination untuk mengambil hasil dalam batch yang lebih kecil. Gunakan --max-results parameter untuk menentukan jumlah maksimum partisi yang akan dikembalikan, dan gunakan --next-token parameter untuk mengambil halaman hasil berikutnya.

aws kafka describe-topic-partitions --cluster-arn ClusterArn --topic-name TopicName --max-results 10

Jika ada lebih banyak hasil yang tersedia, responsnya mencakup nextToken nilai. Gunakan token ini untuk mengambil halaman hasil berikutnya.

aws kafka describe-topic-partitions --cluster-arn ClusterArn --topic-name TopicName --max-results 10 --next-token NextToken

Kasus penggunaan umum

Melihat informasi partisi berguna untuk beberapa skenario:

  • Mengidentifikasi partisi yang kurang direplikasi — Bandingkan replicas dan isr daftar untuk mengidentifikasi partisi di mana beberapa replika tidak sinkron. Ini dapat menunjukkan masalah kinerja atau masalah broker.

  • Memantau distribusi partisi — Periksa apakah pemimpin partisi didistribusikan secara merata di seluruh broker untuk memastikan beban seimbang.

  • Memecahkan masalah replikasi — Identifikasi broker mana yang mengalami kesulitan mengikuti replikasi dengan memeriksa daftar ISR.

  • Perencanaan penyeimbangan kembali partisi - Gunakan informasi ini untuk memahami tata letak partisi saat ini sebelum melakukan operasi penyeimbangan kembali.