遷移到 Apache Kafka 生態系統的 Azure 事件中樞
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 的事件中樞,請參閱下列文章: