Zeigen Sie Partitionsinformationen an, indem Sie AWS CLI - Amazon Managed Streaming für Apache Kafka
Grundlegendes zu PartitionsinformationenErgebnisse paginierenHäufige Anwendungsfälle

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Zeigen Sie Partitionsinformationen an, indem Sie AWS CLI

Führen Sie den folgenden Befehl aus und ClusterArn ersetzen Sie ihn durch den Amazon-Ressourcennamen (ARN) Ihres Clusters und TopicName durch den Namen des Themas.

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

Die Ausgabe dieses -Befehls sieht wie das folgende JSON-Beispiel aus.

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

Grundlegendes zu Partitionsinformationen

Die Antwort enthält die folgenden Informationen für jede Partition:

  • partition — Die Partitionsnummer. Partitionen werden ab 0 nummeriert.

  • leader — Die Broker-ID des Leaders für diese Partition. Der Leader bearbeitet alle Lese- und Schreibanforderungen für die Partition.

  • Repliken — Die Liste der Broker IDs , die über Replikate dieser Partition verfügen. Dazu gehören sowohl synchrone als auch Replikate. out-of-sync

  • isr — Die Liste der Broker, bei denen es sich um synchrone IDs Replikate handelt. Diese Replikate haben sich vollständig an den Leader gehalten und können bei Bedarf die Führung übernehmen.

Im obigen Beispiel hat Partition 2 ein out-of-sync Replikat. Die replicas Liste enthält Broker 2, die isr Liste jedoch nicht. Dies deutet darauf hin, dass Broker 2 nicht vollständig mit dem Leader für diese Partition Schritt gehalten hat.

Ergebnisse paginieren

Wenn Ihr Thema viele Partitionen hat, können Sie die Paginierung verwenden, um Ergebnisse in kleineren Batches abzurufen. Verwenden Sie den --max-results Parameter, um die maximale Anzahl von Partitionen anzugeben, die zurückgegeben werden sollen, und verwenden Sie den --next-token Parameter, um die nächste Ergebnisseite abzurufen.

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

Wenn mehr Ergebnisse verfügbar sind, enthält die Antwort einen nextToken Wert. Verwenden Sie dieses Token, um die nächste Ergebnisseite abzurufen.

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

Häufige Anwendungsfälle

Das Anzeigen von Partitionsinformationen ist in verschiedenen Szenarien nützlich:

  • Zu wenig replizierte Partitionen identifizieren — Vergleichen Sie die isr Listen replicas und, um Partitionen zu identifizieren, bei denen einige Replikate nicht synchron sind. Dies kann auf Leistungsprobleme oder Brokerprobleme hinweisen.

  • Überwachung der Partitionsverteilung — Stellen Sie sicher, dass die Partitionsleiter gleichmäßig auf die Broker verteilt sind, um eine ausgewogene Auslastung zu gewährleisten.

  • Behebung von Replikationsproblemen — Identifizieren Sie anhand der ISR-Liste, welche Broker Probleme haben, mit der Replikation Schritt zu halten.

  • Planung der Neuverteilung von Partitionen — Verwenden Sie diese Informationen, um sich mit dem aktuellen Partitionslayout vertraut zu machen, bevor Sie die Neuverteilung durchführen.