Sdílet prostřednictvím


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

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

Connection string

Postupujte podle kroků v článku: Získání připojovací řetězec z portálu. A poznamenejte si připojovací řetězec pro pozdější použití.

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

Možná budete potřebovat také plně kvalifikovaný název domény, který odkazuje na váš obor názvů služby Event Hubs. Plně kvalifikovaný název domény najdete v připojovací řetězec následujícím způsobem:

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 vaší 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, musíte aktualizovat konfigurace klienta Kafka. Pokud máte potíže s nalezením, zkuste vyhledat, kde bootstrap.servers je ve vaší aplikaci nastavená.

Do aplikace vložte následující konfigurace všude, kde má smysl. Nezapomeňte aktualizovat bootstrap.servers hodnoty a sasl.jaas.config směrovat klienta na koncový bod Event Hubs Kafka 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 v rozhraní není podporovaná konfigurace, vyhledejte konfigurace, které se používají k nastavení uživatelského jména a hesla sasL (Simple Authentication and Security Layer) a jejich použití. Nastavte uživatelské jméno $ConnectionString a heslo do služby Event Hubs připojovací řetězec.

Po migraci

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

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: