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

Статья
12/19/2024

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

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

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

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

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

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

Connection string

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

Полное доменное имя (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 см. в следующих статьях:

Поделиться через