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.

    Immagine del portale con il dashboard del cluster selezionato.

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

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

    Scheda elenco dei servizi Apache Ambari.

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

    Scheda Configurazioni del servizio Apache Ambari.

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

    Campo del filtro di ricerca Apache Ambari.

    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.

    Immagine della voce auto.create.topics.enable.

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

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 relativo ai cluster HDInsight gestiti con l'API REST 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: