Kafka消息系统教程

     

从反应式角度看Apache Kafka

1353 16K
反应式系统应该是有弹性,实现这一目标的一种方法是让我们的应用程序彼此相邻地多次部署,如果一个实例出现故障,将会有其他实例负责其任务,从而为系统增加了更多的弹性。如果需要更多处理能力,可以临时调整更多实.

通过Kafka分布式事务实现微服务数据交换与发件箱模式

3525 3 32K
作为其业务逻辑的一部分,微服务通常不仅需要更新自己的本地数据存储,而且还需要向其他服务通知发生的数据更改。发件箱模式描述了一种让服务以安全和一致的方式执行这两项任务的方法; 它为源服务提供即时“读取您.

关于使用Spring Boot的Kafka教程 - DZone大数据

1801 6K

关于Kafka背后的体系结构及其pub-sub模型的教程,以及我们如何使用流行的Java框架Spring Boot。Apache Kafka是一个分布式流媒体平台,具有发布和订阅记录流,以容错方式存储.

Spring Boot和Apache Kafka结合实现错误处理,消息转换和事务支持?

3984 13K

Spring为Kafka带来了熟悉的Spring编程模型。它提供了KafkaTemplate用于发布记录和用于异步执行POJO侦听器的侦听器容器。Spring Boot自动配置连接了大部分基础架构,因.

Spring Cloud Stream对Kafka Streams的深度支持

3003 9K

在编写流处理应用程序时,Spring Cloud Stream提供了另一个专门用于Kafka Streams的绑定器。与常规Kafka绑定器一样,Kafka Streams绑定器也专注于开发人员的工作.

Spring Cloud Stream如何深度支持Apache Kafka?

3403 7K

Spring Cloud Stream提供了一种编程模型,可以立即连接到Apache Kafka。应用程序需要在其类路径中包含Kafka绑定器并添加一个名为的注释@EnableBinding,该注释将.

reactor-kafka:使用Reactor的反应性Kafka实现程序

3423 8K

这是使用Reactor的Kafka案例方式,生产者代码如下:/** * Sample producer application using Reactive API for Kafka. * To r.

Kubernetes+Docker系统的级联停机故障教训 - Dan Woods

968 3K

Tar​​get的数据中心中运行了许多异构基础架构,为不同的工作负载提供多个不同的后端托管基础架构。其中大部分投入生产的基础架构是用于不同用例和应用程序开发和部署模式的遗留工件。比如目标应用平台(TA.

基于Spring Integration的Apache Kafka JMS消费者

1809 8K

让我们总结一下从Apache Kafka编写JMS消费者时需要知道的基本功能: Kafka没有跟踪哪些消息被消费而言,Apache Kafka是无状态的。这是JMS消费者的责任。这种简单性使Kafka.

Apache Kafka和Spring Integration的使用

1941 7K

Apache Kafka当然是最常用的JMS代理,它有Apache Hadoop等分布式系统用于数据入口。与其他JMS代理相比,Apache Kafka的关键特性(从我的观点来看): Apache K.

使用Spring Boot的Kafka消息机制实现请求响应模型

2738 1 3K

Spring Apache Kafka (spring-kafka)提供了基于卡夫卡的消息传递解决方案的高级抽象。传统的请求响应模型中,响应容易被堵塞,造成两个系统耦合,调用者需要等待到响应返回才能继.

Kafka消费者自动提交配置会导致潜在的重复或数据丢失!

6828 1 2K

在New Relic,我们使用Apache Kafka构建了管道的一些关键部分。多年来,我们遇到了很多问题,并设计了管理Kafka集群的最佳实践。我们已经从中学到了很多关于Kafka如何有效而不是那么.

如何为Kafka设置OAuth2安全机制?

4609 2 9K

随着Kafka版本2.0.0 的KIP-255(Kafka改进提案)的提交,现在我们可以使用SASL(简单认证和安全层)OAUTHBEARER来验证客户端到代理或中间人身份验证。先决条件 Docker.