Migrace na službu Azure Event Hubs pro ekosystémy Apache Kafka

Služba Azure Event Hubs zpřístupňuje koncový bod Apache Kafka, který umožňuje připojení ke službě Event Hubs s využitím protokolu Kafka. Jen s minimálními změnami stávající aplikace Kafka se můžete připojit ke službě Azure Event Hubs, abyste mohli využívat výhody ekosystému Azure. Služba Event Hubs funguje s mnoha stávajícími aplikacemi Kafka, včetně aplikace MirrorMaker. Další informace najdete v tématu Event Hubs pro Apache Kafka.

Před migrací

Vytvoření účtu Azure

Pokud ještě nemáte předplatné Azure, vytvořte si napřed bezplatný účet.

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

Postupujte podle podrobných pokynů v článku Vytvoření centra událostí a vytvořte obor názvů služby Event Hubs a centrum událostí.

Připojovací řetězec

Postupujte podle pokynů v článku Získání připojovacího řetězce z portálu . Poznamenejte si připojovací řetězec pro pozdější použití.

Plně kvalifikovaný název domény (FQDN)

Možná budete také potřebovat plně kvalifikovaný název domény, který odkazuje na váš obor názvů centra událostí. Plně kvalifikovaný název domény najdete v připojovacím řetězci takto:

Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX

Pokud je obor názvů služby Event Hubs nasazený v neveřejném cloudu, může se název domény lišit (například *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net nebo *.servicebus.cloudapi.de).

Migrace

Aktualizace konfigurace klienta Kafka

Pokud se chcete připojit k centru událostí s podporou Kafka, budete muset aktualizovat konfigurace klienta Kafka. Pokud máte potíže najít tu vlastní, zkuste vyhledat, kde bootstrap.servers je ve vaší aplikaci nastaveno.

Vložte následující konfigurace všude, kde má ve vaší aplikaci smysl. Nezapomeňte aktualizovat bootstrap.servers hodnoty a sasl.jaas.config tak, aby se klient nasměrovál na koncový bod Kafka služby Event Hubs se správným ověřováním.

bootstrap.servers={MYNAMESPACE}.servicebus.windows.net:9093
request.timeout.ms=60000
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{CONNECTION STRING TO YOUR NAMESPACE}";

Pokud sasl.jaas.config není podporovaná konfigurace ve vaší architektuře, vyhledejte konfigurace, které se používají k nastavení uživatelského jména a hesla SASL, a použijte je místo nich. Nastavte uživatelské jméno na $ConnectionString a heslo na připojovací řetězec služby Event Hubs.

Po migraci

Spusťte aplikaci Kafka, která odesílá události do centra událostí. Pak pomocí Azure Portal ověřte, že centrum událostí přijímá události. Na stránce Přehled vašeho oboru názvů služby Event Hubs přepněte do zobrazení Zprávy v části Metriky . Aktualizujte stránku a aktualizujte graf. Může trvat několik sekund, než se zobrazí, že zprávy byly přijaty.

Ověřte, že centrum událostí přijalo zprávy.

Další kroky

Další informace o službě Event Hubs a Event Hubs pro Kafka najdete v následujících článcích: