在微服務架構中使用 Kafka 時遇到問題。我無法理解處理 HTTP 請求的微服務如何能夠向用戶發送回應。我想從 HTTP 獲取資料,然后將其發布到名為 A 的主題,然后另一個驗證器服務將驗證它并將其發布到另一個名為 B 的主題上。我想將處理后的資料從主題 B 的訂閱資料發送到 HTTP 回應。
uj5u.com熱心網友回復:
根據我的經驗,一種選擇是立即回應并接受 201,或者將阻塞驗證器庫嵌入到您的 API 中,并正確回傳 400 Bad Request。
然后需要未來的 GET 呼叫來讀取可能從任何消費者回傳的最終一致的資料。例如,消費者行程是寫入某個資料庫的 Kafka 連接器,或者是 Kafka Streams/KSQL 表,API 從中查詢并回傳資料。您的原始客戶端可能需要定期進行 HTTP 事件,直到該資料可用。
轉載請註明出處,本文鏈接:https://www.uj5u.com/yidong/432090.html
