Kafka消息系统教程

本文是David Romero一篇Spring + Kafka Stream实现CQRS的案例代码： 去年九月，我的同事伊万·古铁雷斯和我谈到我们cowokers如何实现事件与Kafka Stream，我开发了一个Kafka Stream，它读取包

Trello过去三年一直在使用RabbitMQ，在RabbitMQ之前，我们还使用了于Redis Pub-Sub实现。最近，由于RabbitMQ在发生网络分区时出现了可疑行为，我们已经切换到了Kafka。 这篇博文深入介绍了我们的RabbitMQ实现，为什

本文分享Kafka最佳实践可以使得管理这个功能强大的数据流平台变得更加容易，而且更加有效。以下是十个有助于保持Kafka部署优化并更易于管理的特定提示：设置日志配置参数以保持日志可管理了解Kafka的（低）硬件要求充分利用Apache Zo

这是Spring Boot使用Kafka入门，生产使用建议Spring Cloud Stream：这里。 1.

大家提到Kafka时第一印象就是它是一个快速的异步消息处理系统，不同于通常tomcat之类应用服务器和前端之间的请求/响应方式请求，客户端发出一个请求，必然会等到一个响应，这种方式对Kafka来说好像不适合，因为Kafka是一种事件驱动方式，通过事件才能激活一个响应，但是，问题来了，很多人习惯请求响

本文是讨论数据库在读写分离情况下，如何实现写数据库的数据如何快速更新到读数据库的三种方式。 Akka Persistence（持久性Akka）是一个相当不错的事件溯源EventSourcing实现。当我们选择EventSourcing架构时，自然同时也会采

EventSourcing事件溯源是存储实体相关的事件流（实则是明细表），而不是直接存储实体的“当前”状态。每个事件都是一个事实，它描述了实体发生的状态变化（过去时态！）。众所周知，事实是无可争议的，不可改变的。拥有这样的事件流可以通过折叠folding与该实体相关的所有事件来找出实

在本文中，我们将讨论如何使用Apache Flink和Apache Ignite构建数据流应用程序。构建数据流应用程序可以以优化和容错的方式将大量有限和无限量的数据提取到Ignite集群中。数据摄取率非常高，每秒可以扩展到数百万个事件。 Apache Ig

这是一篇提供如何从单体大型应用迁移到微服务+事件溯源的指导性文章，文章提供了六条建议，主要是确定微服务边界，将事件作为首要设计，将系统从过去面向接口的耦合变成面向事件数据的耦合，从而大大地增加微服务的独立性和灵活性，同时为性能的弹性扩展提供了可能。所谓面向接口耦合，就是你事先设计几个接口，定义其中的

想Apache Kafka在你自己的电脑上运行，需要Docker，docker-compose，一些磁盘空间和互联网连接。我们将使用来自https://www.confluent

Apache Kafka是一款很酷的产品，但如果你考虑将其用于事件溯源，建议你应该再考虑一下。 Kafka是一个在生产者和消费者之间传递消息的绝佳工具，可选的主题持久性能让你永久存储消息，是的，永远，如果你愿意。

如何使用Debezium向Kafka提交MySQL的更改数据事件? CDC（变更数据捕获

展示如何使用docker-compose为本地开发环境设置自己的Apache Kafka容器，然后使用docker-compose启动和停止docker-image。 要求：1. docker安装（

第1步：生成我们的项目： Spring Initializr来生成我们的项目。我们的项目将提供Spring MVC / Web支持和Apache Kafka支持。第

在基辅召开的JEEConf会议上，Amitay Horwitz描述了他和他的团队如何实施事件溯源的发票系统，他们在生产2年半后遇到的挑战以及他们如何使用Kafka Streams实施新设计。 Wix的软件工程师Horwitz 于2015年开始与他的团队一起

一项新的调查发现，DevOps团队采用微服务的主要原因是扩展应用程序并更快地获得产品和服务的能力。 微服务是敏捷架构的基础，在这种架构上，应用程序被构建为不同的较小服务而不是整个应用程序的集合。新出现的挑战之一是确定这些轻量级服务之间的最佳通信方式。