alpakka kafka

阿尔帕卡·卡夫卡

系统并不是单独出现的。在微服务和云部署的现代世界中，新组件必须与遗留系统交互，这使得集成成为成功的重要关键。反应式流为我们提供了一种独立于技术的工具，让这些异构系​​统能够在不互相压倒的情况下进行通信。

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 相关问题：

• 论坛：discuss.lightbend.com
• 问题跟踪器：

除此之外，您还可以享受以下服务：

• Akka 团队博客
• Twitter 上的@akkateam
• StackOverflow 上标记为 #alpakka 的问题
• StackOverflow 上标记为#alpakka的问题

Kafka 连接器最初是由 .

贡献

Akka 系列项目由 Lightbend 团队在社区的帮助下进行管理。

非常欢迎您的贡献！ Lightbend 感谢 Alpakka 新手和经验丰富的人为社区所做的贡献。

Alpakka 依赖社区来跟上不断增长的集成技术。请站出来与 Alpakka 社区分享您实施的成功 Akka Stream 集成。

如果您发现希望解决的问题，实现这一目标的最快方法是实施修复并提交拉取请求。

有关工作流程的更多详细信息以及有关如何准备拉取请求的一般提示，请参阅 CONTRIBUTING.md 文件。

您还可以直接在 GitHub issues 中寻求澄清或指导。

买者自负

Alpakka 组件在版本之间并不总是二进制兼容。当我们根据您的反馈进行改进和简化时，可能会引入不向后兼容的 API 更改。模块可能会在任何版本中被删除，而无需事先弃用。

执照

Akka 根据商业源代码许可证 1.1 获得许可，请参阅 Akka 许可证常见问题解答。

测试和文档都在单独的许可证下，请参阅每个文档和测试根目录中的 LICENSE 文件以了解详细信息。