【51CTO.com快譯】Apache Kafka的出現(xiàn)，改變了許多企業(yè)重新思考和處置數(shù)據(jù)的方式。它讓包括人壽、醫(yī)療、旅行、車輛等保險行業(yè)，能夠更加高效地使用各類動態(tài)數(shù)據(jù)。本文將從探討事件流的各種用例和架構(gòu)出發(fā)，通過介紹來自Generali、Centene、Mobiliar、Humana、freeyou和Tesla的真實案例，展示保險行業(yè)對于相關數(shù)據(jù)的創(chuàng)新式集成和實時流處理。

保險業(yè)的數(shù)字化轉(zhuǎn)型

長期以來，大多數(shù)保險公司都面臨著如下方面的顯著挑戰(zhàn)：

• 市場環(huán)境極具挑戰(zhàn)。
• 業(yè)務發(fā)展止步不前。
• 監(jiān)管壓力持續(xù)增加。
• 客戶期望不斷變化。
• 老舊應用阻礙發(fā)展。
• 來自創(chuàng)新保險科技公司的新興競爭。
• 來自其他新增保險垂直行業(yè)的新興競爭。

為了避免成為下一個諾基亞(手機領域)、柯達(相機領域)或百視達(BlockBuster，視頻租賃行業(yè))，傳統(tǒng)保險公司需要在如下方面實現(xiàn)戰(zhàn)略轉(zhuǎn)型和創(chuàng)新。

• 包括了：審查、調(diào)查、調(diào)整、匯款、以及拒賠等常規(guī)處理需求。
• 通過利用帶有歷史數(shù)據(jù)的、已訓練好的分析模型，實施索賠欺詐檢測。
• 采用全渠道客戶交互，包括：自助式服務門戶、以及支持自然語言處理(NLP)的自動化聊天機器人工具。
• 基于實驗室測試、生物特征數(shù)據(jù)、索賠數(shù)據(jù)、患者健康數(shù)據(jù)(當然必須遵循特定國家/地區(qū)的法律)的風險預測。

在上述方面，我們可以使用機器學習和深度學習的方式，使得各種手動且易錯過程(如文檔和文本處理)，實現(xiàn)自動化和實時數(shù)據(jù)處理的轉(zhuǎn)變。

棕地集成的必要性

傳統(tǒng)保險公司通常從棕地集成(Brownfield Integration)開始，構(gòu)建新的用例。該集成往往涉及到遺留系統(tǒng)與現(xiàn)代化應用基礎設施的整合，以及數(shù)據(jù)中心與公/私有云原生基礎設施之間的數(shù)據(jù)復制。常見的此類集成場景包括：在傳統(tǒng)中間件中使用MQ、ETL、ESB、以及API工具。而Kafka恰恰是對這些中間件工具的有力補充：

您可以從如下兩篇博文，來深入了解Kafka與中間件、以及API的關系：

• 卡夫卡和傳統(tǒng)中間件，是敵還是友?
•  Apache Kafka與API管理、以及API網(wǎng)關

保險科技(Insurtechs)公司的應用

不同于傳統(tǒng)的保險公司，新興的保險科技的一項巨大優(yōu)勢在于：他們無需與遺留的應用、以及單體架構(gòu)相集成，而完全可以從頭開始新的應用程序。他們既無需集成舊的系統(tǒng)協(xié)議和API，又無需傳統(tǒng)的中間件。也就是說，系統(tǒng)里并不存在諸如：Cobol、EDI或SAP BAPI/iDoc等單一或?qū)Ｓ薪涌凇Ｔ诖祟悎鼍爸校琄afka能夠通過開放接口和實時功能，讓新的應用程序具有敏捷性、可擴展性、以及靈活性。

下圖便是使用Kafka生態(tài)系統(tǒng)，進行索賠處理和欺詐檢測的事件流的架構(gòu)示例。Apache Kafka的使用，可以協(xié)助為保險的索賠處理和欺詐檢測，做出實時決策。

Kafka在保險行業(yè)的六大部署實例

1. Generali：以Kafka作為集成平臺

Generali是全球十大保險公司之一。其General瑞士的數(shù)字化轉(zhuǎn)型始于將Confluent 作為戰(zhàn)略整合平臺，集成了數(shù)百個遺留系統(tǒng)(如關系型數(shù)據(jù)庫等)。在流程上，變更數(shù)據(jù)捕獲 (Change Data Capture，CDC)會將各種變更，實時地推送到作為數(shù)據(jù)中樞和集成平臺的Kafka處，以便其他實時與批處理應用程序，能夠進一步使用和處理這些事件。

Kafka憑借著其獨特的優(yōu)勢，能夠讓系統(tǒng)內(nèi)所有的應用程序都相互解耦。而這對于傳統(tǒng)的消息傳遞(MQ)系統(tǒng)、或SOAP/REST等Web服務，則無法實現(xiàn)真正​​的解耦和域驅(qū)動設計(domain-driven design，DDD)。

Generali云原生架構(gòu)的設計原則

如下圖所示，Generali的集成平臺架構(gòu)利用了Kubernetes、Apache Kafka和變更數(shù)據(jù)捕獲，在云原生基礎設施中提供對于事件流的支持。其關鍵性設計原則包括了：敏捷性、可擴展性、云治理、以及數(shù)據(jù)與事件處理。

而如下有關集成的邏輯圖則展示了Generali的可擴展式微服務架構(gòu)。其流式ETL過程包括了數(shù)據(jù)集成、以及數(shù)據(jù)處理的解耦環(huán)境：

2. Centene的實時大規(guī)模集成和數(shù)據(jù)處理

Centene是美國最大的醫(yī)療補助和保險管理護理的提供商。作為一家為政府資助和私人醫(yī)療保險提供保健計劃的中介，該醫(yī)療保險機構(gòu)的企業(yè)愿景是“逐個改變社區(qū)健康”。在業(yè)務增長的過程中，Centene需要通過一個可擴展且可靠的數(shù)據(jù)集成平臺，來處理各種并購。據(jù)此，Centene看中了Kafka的如下能力：

• 高度可擴展性。
• 高度自治和解耦。
• 高度可用性和數(shù)據(jù)彈性。
• 實時數(shù)據(jù)傳輸。
• 復雜的流處理能力。

在架構(gòu)上，Centene使用Kafka來進行數(shù)據(jù)集成和編排。如下圖所示，傳統(tǒng)數(shù)據(jù)庫、MongoDB、以及應用程序和API，以實時、批處理和請求響應的方式，對數(shù)據(jù)實施大規(guī)模的集成和實時處理。

3. Swiss Mobiliar的解耦和編排

Swiss Mobiliar(又名 Die Mobiliar)是瑞士歷史上最為悠久的私人保險公司。它用到的帶有Kafka事件流支持的各種用例包括：

• 將Orchestrator應用用于跟蹤計費流程的狀態(tài)。
• 將Kafka作為數(shù)據(jù)庫，將Kafka Streams用于數(shù)據(jù)處理。
• 通過各種跨合約和重新計算的方式，實現(xiàn)復雜的狀態(tài)聚合。
• 持續(xù)實時監(jiān)控。

如下架構(gòu)顯示了應用程序和事件編排的解耦：

此外，您也可以通過查看Mobiliar和Spoud網(wǎng)絡會議的鏈接，以進一步了解其如何使用Kafka的更多細節(jié)。

4. Humana的實時集成和分析

Humana Inc.是一家以營利為目的的美國健康保險公司。2020年，它在財富500強榜單中位列第52位。Humana通過構(gòu)建一個互操作性的平臺，實現(xiàn)了利用Kafka來進行實時集成和分析。其中包括：

• 以消費者為中心。
• 健康計劃的隱蔽性。
• 供應商的隱蔽性。
• 云端的擴展性和魯棒性。
• 事件的驅(qū)動和實時性。

憑借著Kafka的集成能力，該平臺通過捕獲用戶與支持IBM Watson AI平臺之間的對話流，使用深度學習、NLP實現(xiàn)了：

• 開放式與標準化的工作流集成。
• 實時的、事件驅(qū)動式的患者交互。
• 高度的可擴展性。

5. Freeyou的狀態(tài)流分析

Freeyou是一家汽車保險類科技公司。它提供了出色的用戶體驗，以及后端實時化的價格自動調(diào)整。Freeyou的流處理與分析等關鍵策略，都是由Kafka和ksqlDB提供的商業(yè)模式所支持的。下圖展示了Kafka和KQL在定價引擎、重新計算模塊、以及在啟用流分析中的邏輯結(jié)構(gòu)：

6. 特斯拉也是汽車保險公司

如今，許多車險公司都會利用行車數(shù)據(jù)，來計算保險的價格，進而提供更好的保險服務。而聯(lián)網(wǎng)汽車和V2X(Vehicle to X)的集成，已經(jīng)成為了新的商業(yè)模式。近年來，特斯拉也開展了汽車保險類業(yè)務。目前，它已經(jīng)建立了一個基于Kafka的數(shù)據(jù)平臺基礎設施，并每天支持著數(shù)百萬臺設備和數(shù)萬億個數(shù)據(jù)點。下圖是特斯拉在2019年的Kafka峰會上展示的其使用Kafka的演進過程。

通過創(chuàng)建實時的集成管道，Kafka給特斯拉帶來了如下優(yōu)勢：

• 從人類專家驅(qū)動方式轉(zhuǎn)化為自動化的大數(shù)據(jù)與機器學習模式
• 處理各種來自駕駛員行為、車輛技術性能(包括攝像頭、傳感器等)等實時的遠程信息與數(shù)據(jù)
• 更好地評估事故的風險、以及車輛維修的成本
• 通過諸如：自動駕駛、穩(wěn)定控制、防盜系統(tǒng)、防彈鋼材料等新技術，降低風險

如果您想進一步了解Kafka事件流在下一代保險平臺的組成與應用，請參見--https://www.slideshare.net/KaiWaehner/apache-kafka-in-the-insurance-industry-249136708。

小結(jié)

由上文提到的六大保險科技公司的成功部署案例可知，從邊緣部署到多云場景，無處不在的Kafka、及其生態(tài)系統(tǒng)通過支持大規(guī)模的實時數(shù)據(jù)處理，真正地解耦了那些單體的遺留系統(tǒng)，并實現(xiàn)了與云原生基礎設施的良好集成。如果您對低延遲用例、用戶體驗、以及系統(tǒng)架構(gòu)有著本行業(yè)特定需求的話，不妨也試試Kafka消息與數(shù)據(jù)處理模型吧。

原文標題：Apache Kafka in the Insurance Industry，作者：Kai Wähner

【51CTO譯稿，合作站點轉(zhuǎn)載請注明原文譯者和出處為51CTO.com】