#kafka

      更多分类

事件溯源概念深入人心:Kafka将抛弃ZooKeeper,替换为自我管理的元数据仲裁

19-08-05 215 2 banq

这是Kafka的KIP-500提案,目前,Kafka使用ZooKeeper存储有关分区和代理的元数据,并选择其作为Kafka控制器的代理。我们想要删除对ZooKeeper的这种依赖。这将使我们能够以... 详细

Kafka如何实现实时流处理 Part 1 - André Melo

19-07-29 32 banq

Apache Kafka可能主要被称为消息传递中间件,其结构比队列更灵活,但它也使团队能够更低地进入实时数据管道。 使用Kafka的所谓流应用程序具有可扩展性,容错性,并且显示强大的排序和交付保证,... 详细

使用Confluent Kafka,KSQL,Spring Boot和分布式SQL开发物联网应用程序

19-05-28 307 2 banq

展示了如何集成Confluent Kafka,KSQL,Spring Boot和YugaByte DB来开发用于管理物联网(IoT)传感器数据的应用程序。 场景 - 支持物联网的车队管理 一... 详细

通过Spring Boot Webflux实现Reactor Kafka

19-04-20 259 1 banq

在 Apache Kafka简介中, 我们研究了分布式流媒体平台Apache Kafka。这一次,我们将关注Reactor Kafka,这个库可以创建从Project Reactor到Kafka T... 详细

从反应式角度看Apache Kafka

19-04-20 119 banq

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

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

19-03-19 666 2 banq

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

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

19-03-19 103 banq

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

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

19-03-13 291 banq

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

Spring Cloud Stream对Kafka Streams的深度支持

19-03-13 470 banq

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

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

19-03-13 389 banq

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

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

19-02-07 232 banq

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

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

19-01-17 58 banq

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

基于Spring Integration的Apache Kafka JMS消费者

19-01-10 179 banq

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

共有 541 2 3 4 下一页