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

文章 2025-02-18 来自：开发者社区

【Azure Kafka】使用Spring Cloud Stream Binder Kafka 发送并接收 Event Hub 消息及解决并发报错

问题描述根据 Spring Cloud Stream Binder Kafka 发送消息/接收消息的代码示例，只需要配置好 application.yaml 中的 event hub connection string, Event Hub Name就可以正常运行并查看执行结果。但...

阿里云文档 2024-01-17

使用SpringCloud框架接入Kafka并收发消息

Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入云消息队列 Kafka 版并收发消息。

文章 2023-11-07 来自：开发者社区

微服务技术系列教程（36） - SpringCloud-使用Kafka实现消息驱动

引言在前面的两篇博客《微服务技术系列教程（34） - SpringCloud-使用RabbitMQ实现消息驱动》、《微服务技术系列教程（35） - SpringCloud-消息驱动消费者组的实现》，实现了基于默认的RabbitMQ来实现消息驱动，同时实现了消费者轮询分发的功能。现在有个问题？如果现在不想使用RabbitMQ了，想切换至Kakfa，那么该如何实现呢？其实切换相当简单，基于《微服务技....

文章 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-05-19 来自：开发者社区

SpringCloud学习笔记(五)-SpringCloudStream集成kafka（下）

五、发送消息到输出通道/** * kafka消息发送器 * @author dbq * @date 2019/9/26 17:50 */ @Component public class EsKafkaMessageSender { @Autowired private EsChannel channel; /** * 消息发送到默认通道：缺省通道对应缺省...

文章 2022-05-19 来自：开发者社区

SpringCloud学习笔记(五)-SpringCloudStream集成kafka（上）

Spring Cloud Stream是构建消息驱动的微服务应用程序框架。提供统一的接收发送管道以连接到消息代理。通过@EnableBinding注解开启SpringCloudStream的支持。通过@StreamListener注解，使其接收流处理的时间。SpringCloudStream应用模型一、引入依赖包<dependency> <groupId>org....