Hızlı Başlangıç: Kafka protokolünü kullanarak Event Hubs veri akışı

Bu hızlı başlangıçta, protokol istemcilerinizi değiştirmeden Event Hubs kendi kümelerinizi çalıştırmadan nasıl ağ içine akışla akışla alınabilirsiniz? Uygulamalarınız için yalnızca bir yapılandırma değişikliğiyle üretici ve Event Hubs konuşmalarını nasıl kullanabileceğinizi öğrenirsiniz.

Önkoşullar

Bu hızlı başlangıcı tamamlamak için aşağıdaki önkoşulların karşılandığından emin olun:

• Apache Kafka için Event Hubs makalesini okuyun.
• Azure aboneliği. Aboneliğiniz yoksa başlamadan önce ücretsiz bir hesap oluşturun.
• Java Development Kit (JDK) 1.7+.
• Bir Maven ikili arşivini indirin ve yükleyin.
• Git

Event Hubs ad alanı oluşturma

Bir ad alanı Event Hubs, ad alanı için Kafka uç noktası otomatik olarak etkinleştirilir. Kafka protokolünü kullanan uygulamalarınızı olay hub'larına akışla sebilirsiniz. Azure portal kullanarak olay hub'ı oluşturma adım adım yönergeleri izleyerek Event Hubs oluşturun. Ayrılmış bir küme kullanıyorsanız bkz. Ayrılmış kümede ad alanı ve olay hub'ı oluşturma.

Event Hubs’da Kafka ile ileti gönderme ve alma

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

2. azure-event-hubs-for-kafka/quickstart/java/producer sayfasına gidin.

3. src/main/resources/producer.config konumundaki üreticinin yapılandırma ayrıntılarını aşağıdaki şekilde güncelleştirin:

   TLS/SSL:

   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

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

   Oauth:

   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;
   

   CustomAuthenticateCallbackHandler örnek işleyici sınıfının kaynak kodunu burada GitHub bulabilirsiniz.

4. Üretici kodunu çalıştırın ve olayları aşağıdaki Event Hubs:

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

5. azure-event-hubs-for-kafka/quickstart/java/consumer sayfasına gidin.

6. src/main/resources/consumer.config konumundaki tüketicinin yapılandırma ayrıntılarını aşağıdaki şekilde güncelleştirin:

   TLS/SSL:

   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

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

   Oauth:

   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;
   

   CustomAuthenticateCallbackHandler örnek işleyici sınıfının kaynak kodunu burada GitHub bulabilirsiniz.

   Kafkaiçin tüm OAuth örneklerini burada Event Hubs bulabilirsiniz.

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

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

Event Hubs Kafka kümenizin olayları varsa, bu olayları artık tüketiciden almaya başlarsınız.

Sonraki adımlar

Bu makalede, protokol istemcilerinizi değiştirmeden veya kendi kümelerinizi çalıştırmadan Event Hubs akışla veri akışı nasıl tamamlayabilirsiniz? Daha fazla bilgi için bkz. Apache Kafka geliştirici kılavuzu Azure Event Hubs.