Миграция в Центры событий Azure для экосистем Apache Kafka

Статья
06/01/2023

Центры событий Azure предоставляют доступ к конечной точке Apache Kafka, которая позволяет подключаться к Центрам событий с помощью протокола Kafka. После внесения минимальных изменений в существующее приложение Kafka вы сможете подключаться к Центрам событий Azure и пользоваться преимуществами экосистемы Azure. Центры событий работают со многими из ваших существующих приложений Kafka, включая MirrorMaker. Дополнительные сведения см. в разделе Центры событий для Apache Kafka.

Подготовка к миграции

Создание учетной записи Azure

Если у вас еще нет подписки Azure, создайте бесплатную учетную запись, прежде чем начинать работу.

Создание пространства имен Центров событий

Выполните пошаговые инструкции из статьи Создание концентратора событий, чтобы создать пространство имен Центров событий и концентратор событий.

строку подключения.

Выполните действия, описанные в статье Получение строки подключения на портале. Также сохраните строку подключения для дальнейшего использования.

Полное доменное имя (FQDN)

Вам также может потребоваться полное доменное имя, указывающее на пространство имен Центров событий. Полное доменное имя можно найти в строке подключения следующим образом:

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

Если пространство имен Центров событий развернуто в общедоступном облаке, имя домена может быть разным (например, *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net или *.servicebus.cloudapi.de).

Миграция

Обновление конфигурации клиента Kafka

Чтобы подключиться к концентратору событий с поддержкой Kafka, следует обновить конфигурации клиентов Kafka. Если вам не удается найти конфигурацию, попробуйте найти, где в приложении задается bootstrap.servers.

Вставьте следующие конфигурации в том месте приложения, где это будет целесообразно. Обновите значения bootstrap.servers и sasl.jaas.config, чтобы перенаправить клиента на конечную точку Kafka в Центрах событий с надлежащей проверкой подлинности.

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

Если ваша платформа не поддерживает конфигурацию sasl.jaas.config, найдите подходящую конфигурацию, которая позволяет задать имя пользователя и пароль SASL. В качестве имени пользователя задайте $ConnectionString, а в качестве пароля — строки подключения для Центров событий.

После миграции

Запустите приложение Kafka, которое отправляет события в концентратор событий. Затем убедитесь, что концентратор событий получает события, с помощью портала Azure. На странице Обзор пространства имен Центров событий в разделе Метрики перейдите в представление Сообщения. Обновите страницу, чтобы обновить диаграмму. На отображение полученных сообщений может уйти несколько секунд.

Дальнейшие действия

Дополнительные сведения о Центрах событий и Центрах событий для Kafka см. в следующих статьях:

Share via