事件驱动云消息队列 Kafka 版-阿里云

文章 2024-10-12 来自：开发者社区

Flink-07 Flink Java 3分钟上手滚动窗口事件驱动 Kafka TumblingWindow GlobalWindow CountWindow

代码仓库会同步代码到 GitHub https://github.com/turbo-duck/flink-demo 上节进度上节完成了滚动窗口时间驱动 TumblingWindow TimeWindowFunction。本节和上节内容相似，但是上节是...

文章 2023-05-27 来自：开发者社区

「事件驱动架构」技术架构师必看事件溯源，CQRS，流处理和Kafka之间的复杂关系

事件溯源作为一种应用程序架构模式越来越流行。事件源涉及将应用程序进行的状态更改建模为事件的不可变序列或“日志”。事件源不是在现场修改应用程序的状态，而是将触发状态更改的事件存储在不可变的日志中，并将状态更改建模为对日志中事件的响应。我们之前曾写过有关事件源，Apache Kafka及其相关性的文章。在本文中，我将进一步探讨这些想法，并展示流处理（尤其是Kafka Streams）如何帮助将事件源....

文章 2023-05-25 来自：开发者社区

「事件驱动架构」Apache Kafka中的事务

在之前的一篇博客文章中，我们介绍了Apache Kafka®的一次语义。这篇文章介绍了各种消息传递语义，介绍了幂等生成器、事务和Kafka流的一次处理语义。现在，我们将继续上一节的内容，深入探讨Apache Kafka中的事务。该文档的目标是让读者熟悉有效使用Apache Kafka中的事务API所需的主要概念。我们将讨论设计事务API的主要用例、Kafka的事务语义、用于Java客户端的事务A....

文章 2023-05-25 来自：开发者社区

「事件驱动架构」事件溯源，CQRS，流处理和Kafka之间的复杂关系

事件溯源作为一种应用程序架构模式越来越流行。事件源涉及将应用程序进行的状态更改建模为事件的不可变序列或“日志”。事件源不是在现场修改应用程序的状态，而是将触发状态更改的事件存储在不可变的日志中，并将状态更改建模为对日志中事件的响应。我们之前曾写过有关事件源，Apache Kafka及其相关性的文章。在本文中，我将进一步探讨这些想法，并展示流处理（尤其是Kafka Streams）如何帮助将事件源....

文章 2023-05-25 来自：开发者社区

「事件驱动架构」何时使用RabbitMQ或 Kafka?

如果你问自己是否Apache Kafka比RabbitMQ更好或RabbitMQ是否比Apache Kafka更可靠，我想在这里阻止你。本文将从更广泛的角度讨论这两种情况。它关注的是这两个系统提供的功能，并将指导您做出正确的决定，决定何时使用哪个系统。web上的一些文章让Apache Kafka在RabbitMQ面前大出风头，而另一些文章则恰恰相反。我们中的很多人可能会因为听了大肆宣传，跟着人群....

文章 2023-05-25 来自：开发者社区

「事件驱动架构」Kafka vs. RabbitMQ:架构、性能和用例

如果你正在考虑是否卡夫卡RabbitMQ最适合你的用例,请继续阅读,了解这些工具背后的不同的架构和方法,如何处理信息不同,和他们的性能优缺点。我们将讨论的最佳用例的每个工具,当它可能比依赖于一个完整的端到端流处理的解决方案。在这个页面:什么是Apache Kafka和RabbitMQ?Kafkavs RabbitMQ -有什么区别?他们如何处理信息他们的表现如何他们最好的用例流处理的端到端平台什....

文章 2023-05-24 来自：开发者社区

「事件驱动架构」Kafka再平衡协议：静态成员和增量合作再平衡

静态成员为了减少暂时性故障导致的用户重新平衡，Apache Kafka 2.3在KIP-345中引入了静态成员的概念。静态成员关系背后的主要思想是，每个使用者实例附加到一个由group.instance.id配置的惟一标识符。成员关系协议已被扩展，以便通过JoinGroup请求将id传播到代理协调器。如果一个使用者由于临时故障而被重新启动或终止，代理协调器直到session.timeout才会通....

文章 2023-05-24 来自：开发者社区

「事件驱动架构」Apache Kafka再平衡协议：再平衡协议101

自从Apache Kafka 2.3.0以来，Kafka Connect和消费者特别使用的内部再平衡协议经历了几次重大变化。再平衡协议不是一件简单的事情，有时看起来像魔术。在这篇文章中，我建议回到这个协议的基础，也就是Apache Kafka消费机制的核心。然后，我们将讨论其局限性和目前的改进。Kafka和再平衡协议101让我们回到一些基本的东西Apache Kafka是一个基于分布式发布/订阅....

文章 2023-05-24 来自：开发者社区

「事件驱动架构」Kafka中的模式注册表和模式演化

在这篇文章中，我们将通过Kafka模式注册表来研究Kafka中的模式演化和兼容性类型。通过对兼容性类型的良好理解，我们可以安全地随着时间的推移对模式进行更改，而不会无意中破坏生产者或消费者的利益。数据集在我们的“真实世界中的Hadoop开发者”课程中，有一章专门讨论Kafka。在这一章中，我们从Meetup.com直播RSVP数据到Kafka编写我们自己的产品质量，部署就绪，生产者和消费者与Sp....

文章 2023-05-24 来自：开发者社区

【事件驱动架构】全面了解Kafka和RabbitMQ选型(1) -两种不同的消息传递方式

在这一部分中，我们将探讨RabbitMQ和Apache Kafka以及它们的消息传递方法。每种技术在设计的每个方面都做出了截然不同的决定，每种方面都有优点和缺点。我们不会在这一部分得出任何有力的结论，而是将其视为技术的入门，以便我们可以深入探讨该系列的后续部分。RabbitMQRabbitMQ是一个分布式消息队列系统。分布式，因为它通常作为节点集群运行，其中队列分布在节点上，并可选择复制以实现容....

Flink-07 Flink Java 3分钟上手滚动窗口事件驱动 Kafka TumblingWindow GlobalWindow CountWindow

「事件驱动架构」技术架构师必看事件溯源，CQRS，流处理和Kafka之间的复杂关系

「事件驱动架构」Apache Kafka中的事务

「事件驱动架构」事件溯源，CQRS，流处理和Kafka之间的复杂关系

「事件驱动架构」何时使用RabbitMQ或 Kafka?

「事件驱动架构」Kafka vs. RabbitMQ:架构、性能和用例

「事件驱动架构」Kafka再平衡协议：静态成员和增量合作再平衡

「事件驱动架构」Apache Kafka再平衡协议：再平衡协议101

「事件驱动架构」Kafka中的模式注册表和模式演化

【事件驱动架构】全面了解Kafka和RabbitMQ选型(1) -两种不同的消息传递方式

云消息队列 Kafka 版您可能感兴趣

产品推荐