Az Apache Kafka konfigurálása a HDInsighton témakörök automatikus létrehozására

Alapértelmezés szerint a HDInsighton futó Apache Kafka nem engedélyezi az automatikus témakörlétrehozást. Az Apache Ambari használatával engedélyezheti a meglévő fürtök automatikus témakör-létrehozását. Új Kafka-fürt Azure Resource Manager-sablonnal történő létrehozásakor is engedélyezheti az automatikus témakörlétrehozást.

Apache Ambari webes felhasználói felület

Ha az Ambari webes felhasználói felületén keresztül szeretné engedélyezni egy meglévő fürt automatikus témakörlétrehozását, kövesse az alábbi lépéseket:

1. Az Azure Portalon válassza ki a Kafka-fürtöt.

2. A Fürt irányítópultjai között válassza az Ambari kezdőlapját.

   

   Amikor a rendszer kéri, hitelesítse magát a fürt bejelentkezési (rendszergazdai) hitelesítő adataival. Ehelyett közvetlenül https://CLUSTERNAME.azurehdinsight.net/ onnan csatlakozhat az Amabrihez, ahol CLUSTERNAME a Kafka-fürt neve szerepel.

3. Válassza ki a Kafka szolgáltatást a lap bal oldalán található listából.

   

4. Válassza a Konfigurációk lehetőséget a lap közepén.

   

5. A Szűrő mezőbe írja be a következő értékét auto.create: .

   

   Ez a beállítás szűri a tulajdonságok listáját, és megjeleníti a auto.create.topics.enable beállítást.

6. Módosítsa a következő értékretrueauto.create.topics.enable, majd válassza a Mentés lehetőséget. Vegyen fel egy megjegyzést, majd válassza ismét a Mentés lehetőséget.

   

7. Válassza ki a Kafka szolgáltatást, válassza az Újraindítás, majd az Összes érintett újraindítása lehetőséget. Amikor a rendszer kéri, válassza az Összes újraindításának megerősítése lehetőséget.

   

Feljegyzés

Az Ambari-értékeket az Ambari REST API-val is beállíthatja. Ez általában nehezebb, mivel több REST-hívást kell kezdeményeznie az aktuális konfiguráció lekéréséhez, módosításához stb. További információ: HDInsight-fürtök kezelése az Apache Ambari REST API-dokumentum használatával.

Resource Manager-sablonok

Ha Egy Kafka-fürtöt Azure Resource Manager-sablonnal hoz létre, közvetlenül beállíthatja auto.create.topics.enable úgy, hogy hozzáadja egy kafka-broker. Az alábbi JSON-kódrészlet bemutatja, hogyan állíthatja be ezt az értéket a következőre true:

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

Következő lépések

Ebben a dokumentumban megtanulta, hogyan engedélyezheti az Apache Kafka automatikus létrehozását a HDInsighton. A Kafka használatával kapcsolatos további információkért tekintse meg az alábbi hivatkozásokat:

• Apache Kafka-naplók elemzése
• Adatok replikálása Apache Kafka-fürtök között