Dynamisches Hinzufügen von Partitionen zu einem Event Hub (Apache Kafka-Thema)

Event Hubs bietet Nachrichtenstreaming über ein partitioniertes Consumermuster, in dem jeder Consumer nur eine bestimmte Teilmenge oder Partition des Nachrichtenstreams liest. Dieses Muster ermöglicht eine horizontale Skalierung für die Ereignisverarbeitung und bietet andere datenstrombezogene Features, die in Warteschlangen und Themen nicht verfügbar sind. Eine Partition ist eine geordnete Sequenz von Ereignissen, die in einem Event Hub besteht. Neu eingehende Ereignisse werden am Ende dieser Sequenz hinzugefügt. Weitere Informationen zu Partitionen im Allgemeinen finden Sie unter Partitionen.

Sie können die Anzahl der Partitionen zum Zeitpunkt der Erstellung eines Event Hub angeben. In einigen Szenarien müssen Sie Partitionen möglicherweise nach der Erstellung des Event Hub hinzufügen. In diesem Artikel wird beschrieben, wie Sie einem vorhandenen Event Hub dynamisch Partitionen hinzufügen.

Aktualisieren der Partitionsanzahl

In diesem Abschnitt wird erläutert, wie Sie die Partitionsanzahl eines Event Hub auf unterschiedliche Weise (PowerShell, Befehlszeilenschnittstelle usw.) aktualisieren.

PowerShell

Verwenden Sie den PowerShell-Befehl Set-AzEventHub, um Partitionen in einem Event Hub zu aktualisieren.

Set-AzEventHub -ResourceGroupName MyResourceGroupName -Namespace MyNamespaceName -Name MyEventHubName -partitionCount 12

BEFEHLSZEILENSCHNITTSTELLE (CLI)

Verwenden Sie den CLI-Befehl az eventhubs eventhub update, um Partitionen in einem Event Hub zu aktualisieren.

az eventhubs eventhub update --resource-group MyResourceGroupName --namespace-name MyNamespaceName --name MyEventHubName --partition-count 12

Resource Manager-Vorlage

Aktualisieren Sie den Wert der Eigenschaft partitionCount in der Resource Manager-Vorlage, und stellen Sie die Vorlage erneut bereit, um die Ressource zu aktualisieren.

    {
        "apiVersion": "2017-04-01",
        "type": "Microsoft.EventHub/namespaces/eventhubs",
        "name": "[concat(parameters('namespaceName'), '/', parameters('eventHubName'))]",
        "location": "[parameters('location')]",
        "dependsOn": [
            "[resourceId('Microsoft.EventHub/namespaces', parameters('namespaceName'))]"
        ],
        "properties": {
            "messageRetentionInDays": 7,
            "partitionCount": 12
        }
    }

Apache Kafka

Verwenden Sie die API AlterTopics (z. B. über das CLI-Tool kafka-topics), um die Partitionsanzahl zu erhöhen. Weitere Informationen finden Sie unter Modifying Kafka topics (Ändern von Kafka-Themen).

Event Hubs-Clients

Sehen wir uns das Verhalten von Event Hubs-Clients an, wenn die Partitionsanzahl für einen Event Hub aktualisiert wird.

Wenn Sie einem vorhandenen Event Hub eine Partition hinzufügen, empfängt der Event Hub-Client eine MessagingException vom Dienst, mit der die Clients informiert werden, dass Entitätsmetadaten geändert wurden. (Ihr Event Hub ist die Entität, und die Partitionsinformationen sind die Metadaten.) Die AMQP-Links werden von den Clients automatisch erneut geöffnet, sodass die geänderten Metadateninformationen abgerufen werden. Die Clients werden dann normal ausgeführt.

Sender-/Producerclients

Event Hubs umfasst drei Senderoptionen:

• Partitionssender: In diesem Szenario senden Clients Ereignisse direkt an eine Partition. Obwohl Partitionen identifizierbar sind und Ereignisse direkt an sie gesendet werden können, wird von der Verwendung dieses Musters abgeraten. Das Hinzufügen von Partitionen hat keine Auswirkung auf dieses Szenario. Es wird empfohlen, Anwendungen neu zu starten, damit neu hinzugefügte Partitionen erkannt werden können.
• Partitionsschlüsselsender: In diesem Szenario senden Clients die Ereignisse mit einem Schlüssel, sodass sich alle zu dem Schlüssel gehörenden Ereignisse in derselben Partition befinden. In diesem Fall erstellt der Dienst einen Hashwert für den Schlüssel und leitet ihn an die entsprechende Partition weiter. Die Aktualisierung der Partitionsanzahl kann durch Hashänderungen zu Problemen wegen falscher Reihenfolge führen. Wenn Ihnen die Reihenfolge wichtig ist, sollten Sie daher sicherstellen, dass in der Anwendung alle Ereignisse aus vorhandenen Partitionen verarbeitet werden, bevor Sie die Partitionsanzahl erhöhen.
• Roundrobinsender (Standard): In diesem Szenario werden die Ereignisse im Event Hubs-Dienst mittels Roundrobinverfahren partitionsübergreifend gesendet. Zusätzlich wird ein Lastenausgleichsalgorithmus verwendet. Der Event Hubs-Dienst erkennt Änderungen der Partitionsanzahl und sendet Ereignisse innerhalb von wenigen Sekunden nach einer Änderung der Partitionsanzahl an die neuen Partitionen.

Empfänger-/Consumerclients

Event Hubs stellt direkte Empfänger und eine einfache Consumerbibliothek mit dem Namen Ereignisprozessor bereit.

• Direkte Empfänger: Die direkten Empfänger lauschen auf spezifische Partitionen. Das zugehörige Laufzeitverhalten ist nicht betroffen, wenn Partitionen für einen Event Hub aufskaliert werden. Die Anwendung, in der direkte Empfänger verwendet werden, muss die neuen Partitionen abrufen und die Empfänger entsprechend zuweisen.

• Ereignisprozessorhost: Dieser Client aktualisiert die Entitätsmetadaten nicht automatisch. Daher wird eine Erhöhung der Partitionsanzahl nicht abgerufen. Die Neuerstellung einer Ereignisprozessorinstanz führt zum Abruf der Entitätsmetadaten, der wiederum zur Erstellung neuer Blobs für die neu hinzugefügten Partitionen führt. Dies wirkt sich nicht auf bereits vorhandene Blobs aus. Es wird empfohlen, alle Ereignisprozessorinstanzen neu zu starten, um sicherzustellen, dass alle Instanzen die neu hinzugefügten Partitionen erkennen und der Lastenausgleich für die Consumer ordnungsgemäß erfolgt.

  Wenn Sie die alte Version des .NET SDK (WindowsAzure.ServiceBus) verwenden, entfernt der Ereignisprozessorhost einen vorhandenen Prüfpunkt nach dem Neustart, wenn die Partitionsanzahl im Prüfpunkt nicht mit der vom Dienst abgerufenen Partitionsanzahl übereinstimmt. Dieses Verhalten kann sich auf Ihre Anwendung auswirken.

  Am 30. September 2026 werden die Azure Service Bus SDK-Bibliotheken „WindowsAzure.ServiceBus“, „Microsoft.Azure.ServiceBus“ und „com.microsoft.azure.servicebus“ eingestellt, da sie nicht den Azure SDK-Richtlinien entsprechen. Außerdem wird die Unterstützung des SBMP-Protokolls beendet, sodass Sie dieses Protokoll nach dem 30. September 2026 nicht mehr verwenden können. Migrieren Sie vor diesem Datum zu den neuesten Azure SDK-Bibliotheken, die wichtige Sicherheitsupdates und verbesserte Funktionen bieten.

  Obwohl die älteren Bibliotheken noch über den 30. September 2026 hinaus verwendet werden können, erhalten sie keinen offiziellen Support und keine Updates mehr von Microsoft. Weitere Informationen finden Sie in der Ankündigung der Supporteinstellung.

Apache Kafka-Clients

In diesem Abschnitt wird das Verhalten von Apache Kafka-Clients beschrieben, die den Kafka-Endpunkt von Azure Event Hubs verwenden, wenn die Partitionsanzahl für einen Event Hub aktualisiert wird.

Das Verhalten von Kafka-Clients, die Event Hubs mit dem Apache Kafka-Protokoll verwenden, unterscheidet sich von dem von Event Hubs-Clients, die das AMQP-Protokoll verwenden. Kafka-Clients aktualisieren die zugehörigen Metadaten alle metadata.max.age.ms Millisekunden. Diesen Wert geben Sie in den Clientkonfigurationen an. Auch die librdkafka-Bibliotheken verwenden die gleiche Konfiguration. Bei Aktualisierungen der Metadaten werden die Clients über Dienständerungen, darunter auch über Erhöhungen der Partitionsanzahl, informiert. Eine Liste der Konfigurationen finden Sie in den Apache Kafka-Konfigurationen für Event Hubs.

Sender-/Producerclients

Producer legen immer fest, dass Sendeanforderungen das Partitionsziel für jede Gruppe von erstellten Datensätzen enthalten. Daher wird die gesamte Producerpartitionierung auf Clientseite mit der Produceransicht der Brokermetadaten erstellt. Nachdem die neuen Partitionen der Metadatenansicht des Producers hinzugefügt wurden, stehen sie für Produceranforderungen zur Verfügung.

Consumer-/Empfängerclients

Wenn ein Mitglied einer Consumergruppe eine Aktualisierung der Metadaten durchführt und die neu erstellten Partitionen abruft, initiiert das Mitglied einen Gruppenausgleich. Anschließend werden die Consumermetadaten für alle Gruppenmitglieder aktualisiert und die neuen Partitionen über den zugeordneten Ausgleichsleader zugewiesen.

Empfehlungen

• Wenn Sie einen Partitionsschlüssel mit den Produceranwendungen verwenden und Schlüsselhashwerte erforderlich sind, um die Reihenfolge in einer Partition sicherzustellen, wird vom dynamischen Hinzufügen von Partitionen abgeraten.

  Wichtig

  Obwohl die Reihenfolge der vorhandenen Daten beibehalten wird, treten beim Partitionenhashing für Nachrichten, für die nach Änderungen der Partitionsanzahl ein Hashwert erstellt wird, aufgrund der Hinzufügung von Partitionen Fehler auf.

• Das Hinzufügen von Partitionen zu einem vorhandenen Thema oder einer vorhandenen Event Hubs-Instanz wird in folgenden Fällen empfohlen:

  • Beim Verwenden der Standardmethode zum Senden von Ereignissen
  • Bei standardmäßigen Kafka-Partitionierungsstrategien, z. B. der StickyAssignor-Strategie

Nächste Schritte

Weitere Informationen zu Partitionen finden Sie unter Partitionen.