Condividi tramite

Come configurare Apache Kafka in HDInsight per creare automaticamente gli argomenti

  • Articolo

Per impostazione predefinita, Apache Kafka in HDInsight non abilita la creazione automatica degli argomenti. È possibile abilitarla per i cluster esistenti con Apache Ambari. È possibile anche abilitare la creazione automatica di argomenti quando si crea un nuovo cluster Kafka tramite un modello di Azure Resource Manager.

Interfaccia utente Web di Apache Ambari

Per abilitare la creazione automatica di argomenti in un cluster esistente tramite l'interfaccia utente Web Ambari, procedere come segue:

  1. Nella portale di Azure selezionare il cluster Kafka.

  2. In Dashboard del cluster selezionare Home di Ambari.

    Image of the portal with cluster dashboard selected.

    Quando viene chiesto, eseguire l'autenticazione usando le credenziali di accesso (amministratore) per il cluster. È invece possibile connettersi ad Amabri direttamente da https://CLUSTERNAME.azurehdinsight.net/ dove CLUSTERNAME è il nome del cluster Kafka.

  3. Selezionare il servizio Kafka nell'elenco a sinistra della pagina.

    Apache Ambari service list tab.

  4. Selezionare Configs (Configurazioni) nella parte centrale della pagina.

    Apache Ambari service configs tab.

  5. Nel campo Filter (Filtro) immettere il valore auto.create.

    Apache Ambari search filter field.

    Questa impostazione filtra l'elenco delle proprietà e visualizza l'impostazione auto.create.topics.enable .

  6. Modificare il valore di auto.create.topics.enable in truee quindi selezionare Salva. Aggiungere una nota e selezionare di nuovo Salva.

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

  7. Selezionare il servizio Kafka, Restart (Riavvia) e quindi Restart all affected (Riavvia tutti gli elementi interessati). Quando viene chiesto, selezionare Confirm restart all (Conferma riavvio di tutte le istanze).

    `Apache Ambari restart all affected`.

Nota

È possibile anche impostare i valori Ambari tramite l'API REST Ambari. Questo è in genere più difficile, perché è necessario effettuare più chiamate REST per recuperare la configurazione corrente, modificarla e così via. Per altre informazioni, vedere il documento Gestire cluster HDInsight usando l'API REST di Apache Ambari.

Modelli di Resource Manager

Quando si crea un cluster Kafka usando un modello di Azure Resource Manager, è possibile impostare direttamente auto.create.topics.enable aggiungendo l'impostazione in un kafka-broker. Il frammento JSON seguente illustra come impostare questo valore su true:

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

Passaggi successivi

In questo documento è stato appreso come abilitare la creazione automatica di argomenti per Apache Kafka in HDInsight. Per altre informazioni sull'utilizzo di Kafka, vedere i collegamenti seguenti: