Aracılığıyla paylaş

HDInsight üzerinde Apache Kafka'nın konuları otomatik olarak oluşturacak şekilde yapılandırılması

  • Makale

Varsayılan olarak, HDInsight üzerinde Apache Kafka otomatik konu oluşturmayı etkinleştirmez. Apache Ambari kullanarak mevcut kümeler için otomatik konu oluşturmayı etkinleştirebilirsiniz. Azure Resource Manager şablonu kullanarak yeni bir Kafka kümesi oluştururken otomatik konu oluşturmayı da etkinleştirebilirsiniz.

Apache Ambari Web Kullanıcı Arabirimi

Ambari Web kullanıcı arabirimi aracılığıyla mevcut bir kümede otomatik konu oluşturmayı etkinleştirmek için aşağıdaki adımları kullanın:

  1. Azure portalından Kafka kümenizi seçin.

  2. Küme panoları'ndan Ambari giriş'i seçin.

    Image of the portal with cluster dashboard selected.

    İstendiğinde, küme için oturum açma (yönetici) kimlik bilgilerini kullanarak kimlik doğrulaması yapın. Bunun yerine, Kafka kümenizin adı olan amabri'ye https://CLUSTERNAME.azurehdinsight.net/CLUSTERNAME doğrudan bağlanabilirsiniz.

  3. Sayfanın sol tarafındaki listeden Kafka hizmetini seçin.

    Apache Ambari service list tab.

  4. Sayfanın ortasındaki Yapılandırmalar'ı seçin.

    Apache Ambari service configs tab.

  5. Filtre alanına değerini auto.creategirin.

    Apache Ambari search filter field.

    Bu ayar, özellik listesini filtreler ve ayarı görüntüler auto.create.topics.enable .

  6. değerini auto.create.topics.enabletrueolarak değiştirin ve kaydet'i seçin. Not ekleyin ve sonra yeniden Kaydet'i seçin.

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

  7. Kafka hizmetini seçin, Yeniden Başlat'ı ve ardından Etkilenen tümünü yeniden başlat'ı seçin. İstendiğinde Tümünü yeniden başlatmayı onayla'yı seçin.

    `Apache Ambari restart all affected`.

Not

Ambari rest API'sini aracılığıyla Ambari değerlerini de ayarlayabilirsiniz. Geçerli yapılandırmayı almak, değiştirmek vb. için birden çok REST çağrısı yapmanız gerektiğinden bu genellikle daha zordur. Daha fazla bilgi için Apache Ambari REST API kullanarak HDInsight kümelerini yönetme belgesine bakın.

Resource Manager şablonları

Azure Resource Manager şablonu kullanarak bir Kafka kümesi oluştururken, bunu bir kafka-brokeröğesine ekleyerek doğrudan ayarlayabilirsinizauto.create.topics.enable. Aşağıdaki JSON parçacığında bu değerin truenasıl olarak ayarlanacağı gösterilmektedir:

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

Sonraki Adımlar

Bu belgede, HDInsight üzerinde Apache Kafka için otomatik konu oluşturmayı etkinleştirmeyi öğrendiniz. Kafka ile çalışma hakkında daha fazla bilgi edinmek için aşağıdaki bağlantılara bakın: