遷移到 Apache Kafka 生態系統的 Azure 事件中樞

文章
03/04/2024

Azure 事件中樞會公開 Apache Kafka 端點，讓您能夠使用 Kafka 通訊協定連線到事件中樞。幾乎不需要變更現有 Kafka 應用程式，您就可以連線到 Azure 事件中樞，並享受 Azure 生態系統的優點。事件中樞適用於許多現有的 Kafka 應用程式，包括 MirrorMaker。如需詳細資訊，請參閱適用於 Apache Kafka 的事件中樞

移轉前

建立 Azure 帳戶

如尚未擁有 Azure 訂用帳戶，請在開始之前先建立免費帳戶。

建立事件中樞命名空間

遵循建立事件中樞文章內的逐步指示來建立事件中樞命名空間和事件中樞。

Connection string

遵循從入口網站取得連接字串中的步驟。然後記下連接字串以供稍後使用。

完整網域名稱 (FQDN)

您也可能需要指向事件中樞命名空間的 FQDN。 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 的事件中樞，請參閱下列文章：

分享方式：