Hızlı Başlangıç: Azure Event Hubs ve Apache Kafka ile veri akışı

1. Sanal makine için sistem tarafından atanan yönetilen kimliği etkinleştirin. Bir VM'de yönetilen kimliği yapılandırma hakkında daha fazla bilgi için bkz . Azure portalını kullanarak VM'de Azure kaynakları için yönetilen kimlikleri yapılandırma. Azure kaynakları için yönetilen kimlikler, Azure hizmetlerine Microsoft Entra ID üzerinde otomatik olarak yönetilen bir kimlik sağlar. Bu kimliği kullanarak, Microsoft Entra kimlik doğrulamasını destekleyen tüm hizmetlerde kodunuzda kimlik bilgileri bulunmasına gerek kalmadan kimlik doğrulaması yapabilirsiniz.

   

2. Oluşturduğunuz Event Hubs ad alanının Erişim denetim sayfasını kullanarak VM'nin yönetilen kimliğine Azure Event Hubs Veri Sahibi rolü atayın. Azure Event Hubs, Event Hubs kaynaklarına yönelik istekleri yetkilendirmek için Microsoft Entra Id kullanılmasını destekler. Microsoft Entra Id ile Azure rol tabanlı erişim denetimini (Azure RBAC) kullanarak bir kullanıcı veya uygulama hizmet sorumlusu olabilecek bir güvenlik sorumlusuna izin vekleyebilirsiniz.

   1. Azure portalında Event Hubs ad alanınıza gidin. Sol gezinti bölmesinde "Erişim Denetimi (IAM)" bölümüne gidin.

   2. + Ekle'yi ve ardından öğesini seçin Add role assignment.

      

   3. Rol sekmesinde Azure Event Hubs Veri Sahibi'ni ve ardından İleri düğmesini seçin.

      

   4. Üyeler sekmesinde, Erişim ata bölümünde Yönetilen Kimlik'i seçin.

   5. +Üyeleri seç bağlantısını seçin.

   6. Yönetilen kimlikleri seçin sayfasında şu adımları izleyin:

      1. VM'yi içeren Azure aboneliğini seçin.

      2. Yönetilen kimlik için Sanal makine'yi seçin

      3. Sanal makinenizin yönetilen kimliğini seçin.

      4. Sayfanın alt kısmındaki Seç'i seçin.

         

   7. Gözden geçir + Ata'yı seçin.

      

3. VM'yi yeniden başlatın ve yönetilen kimliği yapılandırdığınız VM'de yeniden oturum açın.

4. Kafka için Azure Event Hubs deposunu kopyalayın.

5. Şuraya gidin: azure-event-hubs-for-kafka/tutorials/oauth/java/managedidentity/consumer

6. klasörüne src/main/resources/ geçin ve dosyasını açın consumer.config. değerini Event Hubs ad alanınızın adıyla değiştirin namespacename .

   bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
   security.protocol=SASL_SSL
   sasl.mechanism=OAUTHBEARER
   sasl.jaas.config=org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required;
   sasl.login.callback.handler.class=CustomAuthenticateCallbackHandler;
   

   Not

   Kafka için Event Hubs'a yönelik tüm OAuth örneklerini burada bulabilirsiniz.

7. pom.xml dosyasının bulunduğu Tüketici klasörüne dönün ve Kafka istemcilerinizi kullanarak olay hub'ından tüketici kodunu çalıştırın ve olayları işleyin:

   mvn clean package
   mvn exec:java -Dexec.mainClass="TestConsumer"                                    
   

8. Başka bir komut istemi penceresi başlatın ve adresine azure-event-hubs-for-kafka/tutorials/oauth/java/managedidentity/producergidin.

9. klasörüne src/main/resources/ geçin ve dosyasını açın producer.config. değerini Event Hubs ad alanınızın adıyla değiştirin mynamespace .

10. Dosyanın bulunduğu pom.xml Producer klasörüne dönün ve üretici kodunu çalıştırın ve olayları Event Hubs'a akışla aktarın:

    mvn clean package
    mvn exec:java -Dexec.mainClass="TestProducer"                                    
    

    Üretici penceresinde gönderilen olaylar hakkındaki iletileri görmeniz gerekir. Şimdi, olay hub'ından aldığı iletileri görmek için tüketici uygulaması penceresini denetleyin.

    

1. Kafka için Azure Event Hubs deposunu kopyalayın.

2. azure-event-hubs-for-kafka/quickstart/java/consumer adresine gidin.

3. src/main/resources/consumer.config içindeki tüketicinin yapılandırma ayrıntılarını aşağıdaki gibi güncelleştirin:

   bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
   security.protocol=SASL_SSL
   sasl.mechanism=PLAIN
   sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
   

   Önemli

   değerini Event Hubs ad alanınızın bağlantı dizesi ile değiştirin{YOUR.EVENTHUBS.CONNECTION.STRING}. bağlantı dizesi alma yönergeleri için bkz. Event Hubs bağlantı dizesi alma. Aşağıda örnek bir yapılandırma verilmişti: sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XXXXXXXXXXXXXXXX";

4. Kafka istemcilerinizi kullanarak olay hub'ından tüketici kodunu çalıştırın ve olayları işleyin:

   mvn clean package
   mvn exec:java -Dexec.mainClass="TestConsumer"
   

5. azure-event-hubs-for-kafka/quickstart/java/producer adresine gidin.

6. src/main/resources/producer.config dosyasındaki üreticinin yapılandırma ayrıntılarını aşağıdaki gibi güncelleştirin:

   bootstrap.servers=NAMESPACENAME.servicebus.windows.net:9093
   security.protocol=SASL_SSL
   sasl.mechanism=PLAIN
   sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{YOUR.EVENTHUBS.CONNECTION.STRING}";
   

   Önemli

   değerini Event Hubs ad alanınızın bağlantı dizesi ile değiştirin{YOUR.EVENTHUBS.CONNECTION.STRING}. bağlantı dizesi alma yönergeleri için bkz. Event Hubs bağlantı dizesi alma. Aşağıda örnek bir yapılandırma verilmişti: sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=XXXXXXXXXXXXXXXX";

7. Üretici kodunu çalıştırın ve olayları Event Hubs'a akışla aktarın:

   mvn clean package
   mvn exec:java -Dexec.mainClass="TestProducer"
   

Event Hubs Kafka kümenizde olaylar varsa, bunları tüketiciden almaya başlayacaksınız.