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.

    Obrázek portálu s vybraným řídicím panelem clusteru

    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 Ambari 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.

    Karta seznam služeb Apache Ambari

  4. Vyberte konfigurace uprostřed stránky.

    Karta Konfigurace služby Apache Ambari

  5. Do pole Filtr zadejte hodnotu auto.create.

    Pole vyhledávacího filtru Apache Ambari

    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 .

    Obrázek položky auto.create.topics.enable

  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 restartujte všechny ovlivněné.

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 ve spravovaných clusterech 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: