系統並不是單獨出現的。在微服務和雲端部署的現代世界中,新元件必須與遺留系統交互,這使得整合成為成功的重要關鍵。反應式流為我們提供了一種獨立於技術的工具,讓這些異構體系能夠在不互相壓倒的情況下進行通訊。
Alpakka 專案是一項開源計劃,旨在為 Java 和 Scala 實現流感知、反應式整合管道。它建構在 Akka Streams 之上,從頭開始設計,旨在原生理解流,並為反應式和麵向流的編程提供 DSL,並內建對背壓的支援。 Akka Streams 是一個響應式串流和 JDK 9+ java.util.concurrent.Flow 相容的實現,因此可以與其他實作完全互通。
此儲存庫包含Alpakka Kafka 連接器的原始程式碼。它允許您將 Apache Kafka 連接到 Akka Streams。它以前被稱為Akka Streams Kafka甚至Reactive Kafka 。
Alpakka 儲存庫中列出了與其他技術的 Akka Stream 連接器。
Alpakka 參考文檔
Alpakka Kafka 連接器參考文檔
要跟上最新的 Alpakka 版本,請查看 Alpakka 版本和 Alpakka Kafka 版本。
您可以加入這些群組和聊天來討論和詢問 Akka 和 Alpakka 相關問題:
除此之外,您還可以享受以下服務:
Kafka 連接器最初是由 .
Akka 系列專案由 Lightbend 團隊在社群的協助下進行管理。
非常歡迎您的貢獻! Lightbend 感謝 Alpakka 新手和經驗豐富的人為社區所做的貢獻。
Alpakka 依賴社群來跟上不斷增長的整合技術。請站出來與 Alpakka 社群分享您實施的成功 Akka Stream 整合。
如果您發現希望解決的問題,實現這一目標的最快方法是實施修復並提交拉取請求。
有關工作流程的更多詳細資訊以及有關如何準備拉取請求的一般提示,請參閱 CONTRIBUTING.md 檔案。
您也可以直接在 GitHub issues 中尋求澄清或指導。
Alpakka 元件在版本之間並不總是二進位相容。當我們根據您的回饋進行改進和簡化時,可能會引入不向後相容的 API 變更。模組可能會在任何版本中被刪除,而無需事先棄用。
Akka 根據商業原始碼授權 1.1 取得許可,請參閱 Akka 授權常見問題。
測試和文件都在單獨的許可證下,請參閱每個文件和測試根目錄中的 LICENSE 文件以了解詳細資訊。