迁移到用于 Apache Kafka 的 Azure 事件中心生态系统

项目
06/02/2023

Azure 事件中心公开了一个 Apache Kafka 终结点，使你能够使用 Kafka 协议连接到事件中心。对现有 Kafka 应用程序稍作更改即可连接到 Azure 事件中心并充分利用 Azure 生态系统的优势。事件中心可与许多现有 Kafka 应用程序（包括 MirrorMaker）配合使用。有关详细信息，请参阅适用于 Apache Kafka 的事件中心

预迁移

创建 Azure 帐户

如果没有 Azure 订阅，请在开始前创建一个试用版订阅。

创建事件中心命名空间

按照创建事件中心一文中的分步说明创建事件中心命名空间和事件中心。

连接字符串

按照从门户获取连接字符串一文中的步骤进行操作。另外，请记下连接字符串供以后使用。

完全限定的域名 (FQDN)

你可能还需要指向事件中心命名空间的 FQDN。可以在连接字符串中找到 FQDN，如下所示：

Endpoint=sb://mynamespace.servicebus.chinacloudapi.cn/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX

迁移

更新 Kafka 客户端配置

若要连接到支持 Kafka 的事件中心，需要更新 Kafka 客户端配置。如果在查找配置时遇到问题，请尝试在应用程序中搜索 bootstrap.servers 的设置位置。

在应用程序中的适当位置插入以下配置。确保更新 bootstrap.servers 和 sasl.jaas.config 值，以使用正确的身份验证将客户端定向到事件中心 Kafka 终结点。

bootstrap.servers={MYNAMESPACE}.servicebus.chinacloudapi.cn: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 的事件中心，请参阅以下文章：

通过