Sdílet prostřednictvím

Postup konfigurace Apache Kafka ve službě HDInsight pro automatické vytváření témat

  • Článek

Ve výchozím nastavení Apache Kafka ve službě HDInsight neumožňuje automatické vytváření témat. Automatické vytváření témat pro existující clustery můžete povolit pomocí Apache Ambari. Automatické vytváření témat můžete také povolit při vytváření nového clusteru Kafka pomocí šablony Azure Resource Manageru.

Webové uživatelské rozhraní Apache Ambari

Pokud chcete povolit automatické vytváření témat v existujícím clusteru prostřednictvím webového uživatelského rozhraní Ambari, postupujte následovně:

  1. Na webu Azure Portal vyberte cluster Kafka.

  2. Na řídicích panelech clusteru vyberte domovskou stránku Ambari.

    Image of the portal with cluster dashboard selected.

    Po zobrazení výzvy se ověřte pomocí přihlašovacích údajů (správce) clusteru. Místo toho se můžete připojit k Amabri přímo z https://CLUSTERNAME.azurehdinsight.net/ místa, kde CLUSTERNAME je název vašeho clusteru Kafka.

  3. V seznamu na levé straně stránky vyberte službu Kafka.

    Apache Ambari service list tab.

  4. Vyberte konfigurace uprostřed stránky.

    Apache Ambari service configs tab.

  5. Do pole Filtr zadejte hodnotu auto.create.

    Apache Ambari search filter field.

    Toto nastavení filtruje seznam vlastností a zobrazí auto.create.topics.enable nastavení.

  6. Změňte hodnotu auto.create.topics.enable na truea pak vyberte Uložit. Přidejte poznámku a pak znovu vyberte Uložit .

    Image of the auto.create.topics.enable entry.

  7. Vyberte službu Kafka, vyberte Restartovat a pak vyberte Restartovat všechny ovlivněné. Po zobrazení výzvy vyberte Potvrdit restartování všech.

    `Apache Ambari restart all affected`.

Poznámka:

Hodnoty Ambari můžete také nastavit prostřednictvím rozhraní Ambari REST API. To je obecně obtížnější, protože musíte provést více volání REST pro načtení aktuální konfigurace, úpravu atd. Další informace najdete v tématu Správa clusterů HDInsight pomocí dokumentu rozhraní APACHE Ambari REST API .

Šablony Resource Manageru

Při vytváření clusteru Kafka pomocí šablony Azure Resource Manageru můžete přímo nastavit auto.create.topics.enable jeho přidáním do objektu kafka-broker. Následující fragment kódu JSON ukazuje, jak nastavit tuto hodnotu na true:

"clusterDefinition": {
    "kind": "kafka",
    "configurations": {
        "gateway": {
            "restAuthCredential.isEnabled": true,
            "restAuthCredential.username": "[parameters('clusterLoginUserName')]",
            "restAuthCredential.password": "[parameters('clusterLoginPassword')]"
        },
        "kafka-broker": {
            "auto.create.topics.enable": "true"
        }
    }
}

Další kroky

V tomto dokumentu jste zjistili, jak povolit automatické vytváření témat pro Apache Kafka ve službě HDInsight. Další informace o práci se systémem Kafka najdete na následujících odkazech: