Kafka在保險行業中的應用案例
譯文【51CTO.com快譯】Apache Kafka的出現，改變了許多企業重新思考和處置數據的方式。它讓包括人壽、醫療、旅行、車輛等保險行業，能夠更加高效地使用各類動態數據。本文將從探討事件流的各種用例和架構出發，通過介紹來自Generali、Centene、Mobiliar、Humana、freeyou和Tesla的真實案例，展示保險行業對于相關數據的創新式集成和實時流處理。
保險業的數字化轉型
長期以來，大多數保險公司都面臨著如下方面的顯著挑戰：
- 市場環境極具挑戰。
- 業務發展止步不前。
- 監管壓力持續增加。
- 客戶期望不斷變化。
- 老舊應用阻礙發展。
- 來自創新保險科技公司的新興競爭。
- 來自其他新增保險垂直行業的新興競爭。
為了避免成為下一個諾基亞(手機領域)、柯達(相機領域)或百視達(BlockBuster，視頻租賃行業)，傳統保險公司需要在如下方面實現戰略轉型和創新。
- 包括了：審查、調查、調整、匯款、以及拒賠等常規處理需求。
- 通過利用帶有歷史數據的、已訓練好的分析模型，實施索賠欺詐檢測。
- 采用全渠道客戶交互，包括：自助式服務門戶、以及支持自然語言處理(NLP)的自動化聊天機器人工具。
- 基于實驗室測試、生物特征數據、索賠數據、患者健康數據(當然必須遵循特定國家/地區的法律)的風險預測。
在上述方面，我們可以使用機器學習和深度學習的方式，使得各種手動且易錯過程(如文檔和文本處理)，實現自動化和實時數據處理的轉變。
棕地集成的必要性
傳統保險公司通常從棕地集成(Brownfield Integration)開始，構建新的用例。該集成往往涉及到遺留系統與現代化應用基礎設施的整合，以及數據中心與公/私有云原生基礎設施之間的數據復制。常見的此類集成場景包括：在傳統中間件中使用MQ、ETL、ESB、以及API工具。而Kafka恰恰是對這些中間件工具的有力補充：
您可以從如下兩篇博文，來深入了解Kafka與中間件、以及API的關系：
保險科技(Insurtechs)公司的應用
不同于傳統的保險公司，新興的保險科技的一項巨大優勢在于：他們無需與遺留的應用、以及單體架構相集成，而完全可以從頭開始新的應用程序。他們既無需集成舊的系統協議和API，又無需傳統的中間件。也就是說，系統里并不存在諸如：Cobol、EDI或SAP BAPI/iDoc等單一或專有接口。在此類場景中，Kafka能夠通過開放接口和實時功能，讓新的應用程序具有敏捷性、可擴展性、以及靈活性。
下圖便是使用Kafka生態系統，進行索賠處理和欺詐檢測的事件流的架構示例。Apache Kafka的使用，可以協助為保險的索賠處理和欺詐檢測，做出實時決策。
Kafka在保險行業的六大部署實例
1. Generali：以Kafka作為集成平臺
Generali是全球十大保險公司之一。其General瑞士的數字化轉型始于將Confluent 作為戰略整合平臺，集成了數百個遺留系統(如關系型數據庫等)。在流程上，變更數據捕獲 (Change Data Capture，CDC)會將各種變更，實時地推送到作為數據中樞和集成平臺的Kafka處，以便其他實時與批處理應用程序，能夠進一步使用和處理這些事件。
Kafka憑借著其獨特的優勢，能夠讓系統內所有的應用程序都相互解耦。而這對于傳統的消息傳遞(MQ)系統、或SOAP/REST等Web服務，則無法實現真正的解耦和域驅動設計(domain-driven design，DDD)。
Generali云原生架構的設計原則
如下圖所示，Generali的集成平臺架構利用了Kubernetes、Apache Kafka和變更數據捕獲，在云原生基礎設施中提供對于事件流的支持。其關鍵性設計原則包括了：敏捷性、可擴展性、云治理、以及數據與事件處理。
而如下有關集成的邏輯圖則展示了Generali的可擴展式微服務架構。其流式ETL過程包括了數據集成、以及數據處理的解耦環境：
2. Centene的實時大規模集成和數據處理
Centene是美國最大的醫療補助和保險管理護理的提供商。作為一家為政府資助和私人醫療保險提供保健計劃的中介，該醫療保險機構的企業愿景是“逐個改變社區健康”。在業務增長的過程中，Centene需要通過一個可擴展且可靠的數據集成平臺，來處理各種并購。據此，Centene看中了Kafka的如下能力：
- 高度可擴展性。
- 高度自治和解耦。
- 高度可用性和數據彈性。
- 實時數據傳輸。
- 復雜的流處理能力。
在架構上，Centene使用Kafka來進行數據集成和編排。如下圖所示，傳統數據庫、MongoDB、以及應用程序和API，以實時、批處理和請求響應的方式，對數據實施大規模的集成和實時處理。
3. Swiss Mobiliar的解耦和編排
Swiss Mobiliar(又名 Die Mobiliar)是瑞士歷史上最為悠久的私人保險公司。它用到的帶有Kafka事件流支持的各種用例包括：
- 將Orchestrator應用用于跟蹤計費流程的狀態。
- 將Kafka作為數據庫，將Kafka Streams用于數據處理。
- 通過各種跨合約和重新計算的方式，實現復雜的狀態聚合。
- 持續實時監控。
如下架構顯示了應用程序和事件編排的解耦：
此外，您也可以通過查看Mobiliar和Spoud網絡會議的鏈接，以進一步了解其如何使用Kafka的更多細節。
4. Humana的實時集成和分析
Humana Inc.是一家以營利為目的的美國健康保險公司。2020年，它在財富500強榜單中位列第52位。Humana通過構建一個互操作性的平臺，實現了利用Kafka來進行實時集成和分析。其中包括：
- 以消費者為中心。
- 健康計劃的隱蔽性。
- 供應商的隱蔽性。
- 云端的擴展性和魯棒性。
- 事件的驅動和實時性。
憑借著Kafka的集成能力，該平臺通過捕獲用戶與支持IBM Watson AI平臺之間的對話流，使用深度學習、NLP實現了：
- 開放式與標準化的工作流集成。
- 實時的、事件驅動式的患者交互。
- 高度的可擴展性。
5. Freeyou的狀態流分析
Freeyou是一家汽車保險類科技公司。它提供了出色的用戶體驗，以及后端實時化的價格自動調整。Freeyou的流處理與分析等關鍵策略，都是由Kafka和ksqlDB提供的商業模式所支持的。下圖展示了Kafka和KQL在定價引擎、重新計算模塊、以及在啟用流分析中的邏輯結構：
6. 特斯拉也是汽車保險公司
如今，許多車險公司都會利用行車數據，來計算保險的價格，進而提供更好的保險服務。而聯網汽車和V2X(Vehicle to X)的集成，已經成為了新的商業模式。近年來，特斯拉也開展了汽車保險類業務。目前，它已經建立了一個基于Kafka的數據平臺基礎設施，并每天支持著數百萬臺設備和數萬億個數據點。下圖是特斯拉在2019年的Kafka峰會上展示的其使用Kafka的演進過程。
通過創建實時的集成管道，Kafka給特斯拉帶來了如下優勢：
- 從人類專家驅動方式轉化為自動化的大數據與機器學習模式
- 處理各種來自駕駛員行為、車輛技術性能(包括攝像頭、傳感器等)等實時的遠程信息與數據
- 更好地評估事故的風險、以及車輛維修的成本
- 通過諸如：自動駕駛、穩定控制、防盜系統、防彈鋼材料等新技術，降低風險
如果您想進一步了解Kafka事件流在下一代保險平臺的組成與應用，請參見--https://www.slideshare.net/KaiWaehner/apache-kafka-in-the-insurance-industry-249136708。
小結
由上文提到的六大保險科技公司的成功部署案例可知，從邊緣部署到多云場景，無處不在的Kafka、及其生態系統通過支持大規模的實時數據處理，真正地解耦了那些單體的遺留系統，并實現了與云原生基礎設施的良好集成。如果您對低延遲用例、用戶體驗、以及系統架構有著本行業特定需求的話，不妨也試試Kafka消息與數據處理模型吧。
原文標題：Apache Kafka in the Insurance Industry，作者：Kai Wähner
【51CTO譯稿，合作站點轉載請注明原文譯者和出處為51CTO.com】
