云消息队列 Kafka 版cloud-阿里云

文章 2023-10-09 来自：开发者社区

[实战系列]SelectDB Cloud Kafka Connect 最佳实践张家锋

概述企业正在经历其数据资产的爆炸式增长，这些数据包括批式或流式传输的结构化、半结构化以及非结构化数据，随着海量数据批量导入的场景的增多，企业对于 Data Pipeline 的需求也愈加复杂。新一代云原生实时数仓 SelectDB Cloud 作为一款运行于多云之上的云原生实时数据仓库，致力于通过开箱即用的能力为客户带来简单快速的数仓体验。在生态方面，SelectDB Cloud 提供了丰富的数....

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

「Spring和Kafka」Kafka深挖第3部分：Kafka和Spring Cloud data Flow

作为Apache Kafka深挖的博客系列第1部分和第2部分的后续,在第3部分中我们将讨论另一个Spring 团队的项目:Spring Cloud Data Flow,其重点是使开发人员能够轻松地开发、部署和协调事件流管道基于Apache Kafka。作为前一篇博客系列文章的延续，本文解释了Spring Cloud数据流如何帮助您提高开发人员的工作效率并管理基于apache - kafka的事件....

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

「Spring和Kafka」Kafka整合Spring 深入挖掘第2部分:Kafka和Spring Cloud Stream

在这个博客系列的第1部分之后，Apache Kafka的Spring——第1部分:错误处理、消息转换和事务支持「Spring和Kafka」Kafka整合Spring 深入挖掘 -第1部分，在这里的第2部分中，我们将关注另一个增强开发者在Kafka上构建流应用程序时体验的项目:Spring Cloud Stream。我们将在这篇文章中讨论以下内容:Spring云流及其编程模型概述Apache Ka....

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

「首席架构师看事件流架构」Kafka深挖第3部分：Kafka和Spring Cloud data Flow

作为Apache Kafka深挖的博客系列第1部分和第2部分的后续,在第3部分中我们将讨论另一个Spring 团队的项目:Spring Cloud Data Flow,其重点是使开发人员能够轻松地开发、部署和协调事件流管道基于Apache Kafka。作为前一篇博客系列文章的延续，本文解释了Spring Cloud数据流如何帮助您提高开发人员的工作效率并管理基于apache - kafka的事件....

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

【首席架构师看Event Hub】Kafka深挖 -第2部分:Kafka和Spring Cloud Stream

在这个博客系列的第1部分之后，Apache Kafka的Spring——第1部分:错误处理、消息转换和事务支持，在这里的第2部分中，我们将关注另一个增强开发者在Kafka上构建流应用程序时体验的项目:Spring Cloud Stream。我们将在这篇文章中讨论以下内容:Spring云流及其编程模型概述Apache Kafka®集成在Spring云流Spring Cloud Stream如何让K....

文章 2022-11-27 来自：开发者社区

从零学SpringCloud系列（九）：利用kafka实现消息总线Spring Cloud Bus

一、什么是消息总线相信大多数读者之前都使用过各种各样的消息队列，例如RabbitMQ、kafka等等，消息总线和他的概念差不多，在微服务系统的架构中，我们通常会使用轻量级的消息代理来构建一个共用的消息主题让系统中所有的微服务都连接上来，由于该主题中产生的消息会被所有实例监听和消费，所以我们称他们为消息总线。在总线上的各个实例都可以方便的广播一些需要让其他连接到该主题上的实例都知道的消息，例如....

文章 2022-09-23 来自：开发者社区

StreamNative Cloud for KafkaⓇ新品发布！云上打通 Pulsar 与 Kafka

近日，Apache Pulsar 商业化公司 StreamNative 宣布发布新产品 StreamNative Cloud for KafkaⓇ。此云原生托管服务基于 Apache Pulsar 构建，提供完全兼容的 Kafka API 实现，而不受 Kafka 的限制。同时，StreamNative Cloud for KafkaⓇ 支持为百万级主题提供持续的低延迟。2020 年，Strea....

文章 2021-12-28 来自：开发者社区

Spring Cloud构建微服务架构（七）消息总线（续：Kafka）

Spring Cloud Bus除了支持RabbitMQ的自动化配置之外，还支持现在被广泛应用的Kafka。在本文中，我们将搭建一个Kafka的本地环境，并通过它来尝试使用Spring Cloud Bus对Kafka的支持，实现消息总线的功能。由于本文会以之前Rabbit的实现作为基础来修改，所以先阅读《Spring Cloud构建微服务架构（七）消息总线》有助于理解本文。Kafka简介Kafk....

文章 2021-08-12 来自：开发者社区

Spring Cloud Stream 整合Kafka

Spring Cloud Stream是一个构建消息驱动微服务的框架，抽象了MQ的使用方式, 提供统一的API操作。Spring Cloud Stream通过Binder(绑定器)、inputs/outputschannel完成应用程序和MQ的解耦。Spring Cloud Stream的模型如下图：Binder负责绑定应用程序和MQ中间件,即指定应用程序是和KafKa交互还是和RabbitMQ....

文章 2019-08-11 来自：开发者社区

[Spring cloud 一步步实现广告系统] 16. 增量投送到kafka

实现增量数据索引上一节中，我们为实现增量索引的加载做了充足的准备，使用到mysql-binlog-connector-java 开源组件来实现MySQL 的binlog监听，关于binlog的相关知识，大家可以自行网络查阅。或者可以mailto:magicianisaac@gmail.com 本节我们将根据binlog 的数据对象，来实现增量数据的处理，我们构建广告的增量数据，其实说白了就是.....