springboot云消息队列 Kafka 版的相关内容

文章 2023-06-13 来自：开发者社区

springboot整合kafka和zookeeper简易示例（win平台）

先下载zookeeper：找一个版本，不使用最新版，好像有版本的错误。下载，解压。复制zoo_sample.cfg配置文件，修改文件名为zoo.cfg打开zoo.cfg，修改dataDir为本地磁盘地址，可以新建一个data文件夹。启动zookeeper， zkServer.cmd启动成功下载kafka，下载链接下载，解压。打开config下的server.properties配置文件修改lo....

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

Apache Kafka-SpringBoot整合Kafka发送复杂对象

Spring Kafka概述Spring提供了 Spring-Kafka 项目来操作 Kafka。https://spring.io/projects/spring-kafkaCode我们先对 Kafka-Spring 做个快速入门，实现 Producer发送消息，同时Consumer 消费消息。依赖 <dependencies> <dependency> ...

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

Spring Boot与 Kafka实现高吞吐量消息处理大规模数据问题

一、引言现代数据量越来越庞大对数据处理的效率提出了更高的要求。Apache Kafka是目前流行的分布式消息队列之一。Spring Boot是现代Java应用程序快速开发的首选框架。综合使用Spring Boot和Apache Kafka可以实现高吞吐量消息处理。二、Apache Kafka技术概述 1. Apache Kafka架构 Apache Kafka采用分布式发布-订阅模式具有高度....

文章 2023-04-16 来自：开发者社区

Java：SpringBoot整合Kafka实现数据异步处理

SpringBoot项目中，使用Kafka可以实现数据异步处理目录下载安装KafkaSpringBoot引入Kafka引入依赖pom.xml配置 application.yml消费者生产者消息发送和接收参考下载安装Kafka# 从清华镜像下载 wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.8.2/kafka_2.13-2.8.2....

文章 2023-03-13 来自：开发者社区

Spring Boot集成Kafka动态创建消费者与动态删除主题（实现多消费者的发布订阅模型）

在Spring Boot集成Kafka时，大家都知道可以使用@KafkaListener注解创建消费者。但是@KafkaListener注解是静态的，意味着在编译时就已经确定了消费者，无法动态地创建消费者。不过事实上，使用Kafka提供的Java API，使用KafkaConsumer类就可以完成消费者的动态...

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

基于SpringBoot + MyBatis + Caffeine + Redis + MySql + Kafka实现一个论坛网站附完整代码

功能梳理普通用户权限：支持站内账号登录，QQ 登录和 GitHub 账号登录（一键登录，方便快捷）支持发布帖子，可以添加自定义标签，支持 Markdown 格式，同时编辑页面提供目录索引支持用户编辑自己发布帖子支持点赞帖子，评论帖子，对评论进行评论，对评论进行点赞，当用户的帖子或者评论被点赞或评论时，会通过站内信通知用户查看帖子详情页面时，可以同时看到论坛的热门帖，以及相关的帖子（通过标签匹配获....

文章 2023-01-12 来自：开发者社区

【微服务安全】使用 Spring Boot、Kafka、Vault 和 Kubernetes 保护微服务间通信——第 1 部分：简介和架构

链接第 1 部分：简介和架构 <--本文第 2 部分：设置 Kubernetes 和 Kafka第 3 部分：设置保险柜第 4 部分：构建微服务第 5 部分：部署和测试介绍微服务是一种设计模式，其中大型单体应用程序被分离成更小、更易于管理的组件。这些组件可以协同工作来解决特定的业务问题。为此，组件需要相互通信。组件之间的通信可以通过多种方式实现：RESTful Web 服务、SOAP W....

文章 2023-01-12 来自：开发者社区

【微服务安全】与 Spring Boot、Kafka、Vault 和 Kubernetes 通信——第 2 部分：设置 Kubernetes 和 Kafka

文章 2023-01-12 来自：开发者社区

【微服务安全】使用 Spring Boot、Kafka、Vault 和 Kubernetes 保护微服务间通信——第 3 部分：设置 Vault

第 1 部分：简介和架构第 2 部分：设置 Kubernetes 和 Kafka第 3 部分：设置 Vault <--本文第 4 部分：构建微服务第 5 部分：部署和测试设置Vault 如果我们回想一下我们的架构，我们说过我们将提供端到端加密。虽然 Vault 将保护我们的信息，但谁在保护 Vault？ - 为此，我们将使用经典的 TLS 连接 (HTTPS) 来保护我们与 Va....

文章 2023-01-12 来自：开发者社区

【微服务安全】使用 Spring Boot、Kafka、Vault 和 Kubernetes 保护微服务间通信——第 4 部分：构建微服务

第 1 部分：简介和架构第 2 部分：设置 Kubernetes 和 Kafka第 3 部分：设置保险柜Part 4: 构建微服务 <--本文第 5 部分：部署和测试创建微服务我们将创建 2 个微服务：Transaction 和 DepositAccount。我们将为此使用 JHipster。首先，我们需要安装 JHipster。请按照此处的教程安装 JHipster [htt....