Rychlý Start: streamování dat pomocí Event Hubs s využitím protokolu Kafka

V tomto rychlém startu se dozvíte, jak streamovat do Event Hubs bez změny klientů protokolu nebo spouštění vlastních clusterů. Naučíte se, jak používat vaše producenty a spotřebitelé ke komunikaci s Event Hubs jenom se změnou konfigurace v aplikacích.

Požadavky

Abyste mohli absolvovat tento rychlý start, ujistěte se, že máte následující:

• Přečtěte si článek Event Hubs pro Apache Kafka.
• Předplatné Azure. Pokud ho nemáte, než začnete, vytvořte si bezplatný účet.
• Java Development Kit (JDK) 1.7+.
• Stáhněte a nainstalujte binární archiv Maven.
• Git

Vytvoření oboru názvů služby Event Hubs

Když vytvoříte obor názvů Event Hubs, je automaticky povolen koncový bod Kafka pro obor názvů. Můžete streamovat události z vašich aplikací, které používají protokol Kafka, do Center událostí. Postupujte podle podrobných pokynů v tématu vytvoření centra událostí pomocí Azure Portal k vytvoření oboru názvů Event Hubs. Pokud používáte vyhrazený cluster, přečtěte si téma Vytvoření oboru názvů a centra událostí ve vyhrazeném clusteru.

Odesílání a příjem zpráv pomocí Kafka ve službě Event Hubs

1. Naklonujte úložiště Azure Event Hubs pro ekosystém Kafka.

2. Přejděte na adresu azure-event-hubs-for-kafka/quickstart/java/producer.

3. Aktualizujte podrobnosti o konfiguraci producenta v src/main/resources/producer.config následujícím způsobem:

   PROTOKOL 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}";
   

   Důležité

   Nahraďte {YOUR.EVENTHUBS.CONNECTION.STRING} připojovacím řetězcem pro váš Event Hubs obor názvů. Pokyny k získání připojovacího řetězce najdete v tématu získání připojovacího řetězce Event Hubs. Tady je příklad konfigurace: 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;
   

   zdrojový kód pro třídu obslužné rutiny sample CustomAuthenticateCallbackHandler na GitHub najdete zde.

4. Spusťte kód producenta a streamování událostí do Event Hubs:

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

5. Přejděte na adresu azure-event-hubs-for-kafka/quickstart/java/consumer.

6. Aktualizujte podrobnosti o konfiguraci příjemce v src/main/resources/consumer.config následujícím způsobem:

   PROTOKOL 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}";
   

   Důležité

   Nahraďte {YOUR.EVENTHUBS.CONNECTION.STRING} připojovacím řetězcem pro váš Event Hubs obor názvů. Pokyny k získání připojovacího řetězce najdete v tématu získání připojovacího řetězce Event Hubs. Tady je příklad konfigurace: 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;
   

   zdrojový kód pro třídu obslužné rutiny sample CustomAuthenticateCallbackHandler na GitHub najdete zde.

   Všechny ukázky OAuth pro Event Hubs pro Kafka najdete tady.

7. Spusťte kód příjemce a zpracujte události z centra událostí pomocí klientů Kafka:

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

Pokud váš cluster Event Hubs Kafka obsahuje události, začnete je teď přijímat od příjemce.

Další kroky

V tomto článku jste zjistili, jak se streamovat do Event Hubs bez změny klientů protokolu nebo spouštění vlastních clusterů. Další informace najdete v tématu Apache Kafka příručka pro vývojáře pro Azure Event Hubs.