消息服务--Kafka的简介和使用

news2025/11/4 19:00:26

消息服务--Kafka的简介和使用

  • 前言
    • 异步
    • 解耦
    • 削峰
    • 缓存
  • 1、消息队列
  • 2、kafka工作原理
  • 3、springBoot KafKa整合
    • 3.1 添加插件
    • 3.2 kafKa的自动配置类
      • 3.21 配置kafka地址
      • 3.22 如果需要发送对象配置kafka值的序列化器
    • 3.3 测试发送消息
      • 3.31 在发送测试消息的时候由于是开发环境中会遇到的问题
  • 3.4 监听消息-kafkaListener

前言

异步

在这里插入图片描述

解耦

在这里插入图片描述

削峰

在这里插入图片描述

缓存

在这里插入图片描述

1、消息队列

在这里插入图片描述

2、kafka工作原理

在这里插入图片描述

3、springBoot KafKa整合

3.1 添加插件

安装完成后需要刷新maven

在这里插入图片描述
在这里插入图片描述

3.2 kafKa的自动配置类

kafkaautoConfiguration 自动配置提供了以功能
1、KafkaProperties: kafka的所有配置 以spring.kafka 开始
	- bootstrapServers: kafka集群的所有服务器地址
	- properties: 参数设置
	- consumer: 消费者
	- producer: 生产者
2、 @EnableKafka: 开启Kafka的注解驱动功能
3、 KafkaTemplate: 收发消息
4、 KafkaAdmin: 维护主题等......

3.21 配置kafka地址

//两种方式
spring.kafka.bootstrap-servers[0] = 8.130.32.72:9092
//也可以通过逗号分隔
spring.kafka

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1504793.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

flask-sqlalchemy库

flask-sqlalchemy库

彩笔激流勇退。 1. 简介 ORM，对象关系映射。简单来说，ORM将数据库中的表与面向对象中的类建立了一种对应关系。这样，我们要操作数据库，表，记录就可以直接通过操作类或者类实例来完成。 SQLAlchemy 是目前python中最…
阅读更多...
连接时序分类 Connectionist Temporal Classification (CTC)

连接时序分类 Connectionist Temporal Classification (CTC)

CTC全称Connectionist temporal classification，是一种常用在语音识别、文本识别等领域的算法，用来解决输入和输出序列长度不一、无法对齐的问题。在CRNN中，它实际上就是模型对应的损失函数(CTC loss)。 一、背景 字母和语音的对齐(align)非…
阅读更多...
Redis 内存的优化

Redis 内存的优化

目录 前言 Redis 的内存碎片问题 判断Redis 内存碎片 如何清理内存碎片？ 前言 我想讲一下怎么提高Redis 内存的利用率，redis 的数据是保存在内存中。对内存的利用率低，意味着存的数据很少，并不意味着就没有内存了&#xff0c…
阅读更多...
React-路由导航

React-路由导航

1.声明式路由导航 1.1概念 说明&#xff1a;声明式导航是指通过在模版中通过<Link/>组件描述出要跳转到哪里去&#xff0c;比如后台管理系统的左侧菜单通常使用这种方式进行。 import {Link} from "react-router-dom" const Login()>{return (<div>…
阅读更多...
[nlp入门论文精读] | Transformer

[nlp入门论文精读] | Transformer

写在前面 最近工作从CV转向了NLP&#xff0c;于是空余时间便跟着哔哩哔哩李沐老师的视频学习。其实研一NLP课程讲论文的时候&#xff0c;我们小组就选择了经典的Attention和Bert&#xff0c;但还有很多细节并不完全理解&#xff0c;实际使用时也很困惑。 因此这个系列就来记…
阅读更多...
Spring学习 基础（三）MVC

Spring学习 基础（三）MVC

5、Spring MVC 传统Web模式&#xff1a; Model:系统涉及的数据&#xff0c;也就是 dao 和 bean。View&#xff1a;展示模型中的数据&#xff0c;只是用来展示。Controller&#xff1a;处理用户请求都发送给 &#xff0c;返回数据给 JSP 并展示给用户。 随着 Spring 轻量级开发…
阅读更多...
【python】time库知识整理

【python】time库知识整理

简介 python的time库是python内置库&#xff0c;主要负责处理与时间相关的事务。 获取当前时间 函数作用time()获取当前时间戳ctime()获取字符串形式的时间gmtime()调用内部方法&#xff0c;赋予属性&#xff0c;能够被程序调用执行 time返回的是时间戳 ctime是返回的我们…
阅读更多...
智慧安防视频远程监控平台EasyCVR集成后播放只有一帧画面是什么原因？

智慧安防视频远程监控平台EasyCVR集成后播放只有一帧画面是什么原因？

智慧安防视频监控平台EasyCVR能在复杂的网络环境中&#xff08;专网、局域网、广域网、VPN、公网等&#xff09;将前端海量的设备进行统一集中接入与视频汇聚管理&#xff0c;平台可支持的接入协议包括&#xff1a;国标GB28181、RTSP/Onvif、RTMP&#xff0c;以及厂家的私有协议…
阅读更多...
Linux网络套接字之预备知识

Linux网络套接字之预备知识

(&#xff61;&#xff65;∀&#xff65;)&#xff89;&#xff9e;嗨&#xff01;你好这里是ky233的主页&#xff1a;这里是ky233的主页&#xff0c;欢迎光临~https://blog.csdn.net/ky233?typeblog 点个关注不迷路⌯▾⌯ 目录 一、预备知识 1.理解源IP地址和目的IP地址 …
阅读更多...
Day27：安全开发-PHP应用TP框架路由访问对象操作内置过滤绕过核心漏洞

Day27：安全开发-PHP应用TP框架路由访问对象操作内置过滤绕过核心漏洞

目录 TP框架-开发-配置架构&路由&MVC模型 TP框架-安全-不安全写法&版本过滤绕过 思维导图 PHP知识点 功能&#xff1a;新闻列表&#xff0c;会员中心&#xff0c;资源下载&#xff0c;留言版&#xff0c;后台模块&#xff0c;模版引用&#xff0c;框架开发等 技…
阅读更多...
Android14之解决报错：No module named sepolgen(一百九十二)

Android14之解决报错：No module named sepolgen(一百九十二)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 优质专栏&#xff1a;多媒…
阅读更多...
excel统计分析——嵌套设计

excel统计分析——嵌套设计

参考资料&#xff1a;生物统计学&#xff0c;巢式嵌套设计的方差分析 嵌套设计&#xff08;nested design&#xff09;也称为系统分组设计或巢式设计&#xff0c;是把试验空间逐级向低层次划分的试验设计方法。与裂区设计相似&#xff0c;先按一级因素设计试验&#xff0c;然后…
阅读更多...
LeetCode-1004. 最大连续1的个数 III

LeetCode-1004. 最大连续1的个数 III

每日一题系列&#xff08;day 20&#xff09; 前言&#xff1a; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f50…
阅读更多...
【OpenCV】如何在Linux操作系统下正确安装 OpenCV

【OpenCV】如何在Linux操作系统下正确安装 OpenCV

前言 我是在虚拟机上跑的 Linux 5.8.0-44-generic。 配置如下&#xff1a; 目录 第一步&#xff1a;下载依赖文件 第二步&#xff1a;下载 opencv 和 opencv_contrib 源码 第三步&#xff1a;解压缩包 第四步&#xff1a;移动文件 第五步&#xff1a;生成 makefile 文件 …
阅读更多...
oracle基础-多表关联查询 备份

oracle基础-多表关联查询 备份

一、概述 在实际应用系统开发中会设计多个数据表&#xff0c;每个表的信息不是独立存在的&#xff0c;而是若干个表之间的信息存在一定的关系&#xff0c;当用户查询某一个表的信息时&#xff0c;很可能需要查询关联数据表的信息&#xff0c;这就是多表关联查询。SELECT语句自身…
阅读更多...
Prometheus添加nginx节点显示不支持stub_status 解决办法

Prometheus添加nginx节点显示不支持stub_status 解决办法

1、我们在使用Prometheus监控添加nginx节点监控的时候&#xff0c;在被监控节点的nginx配置文件中添加下面的模块 server { listen 80; server_name localhost; location /stub_status { stub_status on; access_log off; …
阅读更多...
【解读】OWASP 大语言模型（LLM）安全测评基准V1.0

【解读】OWASP 大语言模型（LLM）安全测评基准V1.0

大语言模型&#xff08;LLM&#xff0c;Large Language Model&#xff09;是指参数量巨大、能够处理海量数据的模型, 此类模型通常具有大规模的参数&#xff0c;使得它们能够处理更复杂的问题&#xff0c;并学习更广泛的知识。自2022 年以来&#xff0c;LLM技术在得到了广泛的应…
阅读更多...
网络触手获取天气数据存入mysql 项目

网络触手获取天气数据存入mysql 项目

首先这个案例不一定能直接拿来用&#xff0c;虽然我觉得可以但是里面肯定有一些我没考虑到的地方。 有问题评论或者私信我&#xff1a; 这个案例适合我这种学生小白 获取天气数据网址&#xff1a; https://lishi.tianqi.com/xianyang/202201.html 网络触手获取天气数据代码直…
阅读更多...
这是一段神奇的提示词，能直接调取Claude 3的系统提示词！附详细解读

这是一段神奇的提示词，能直接调取Claude 3的系统提示词！附详细解读

大家好&#xff0c;我是木易&#xff0c;一个持续关注AI领域的互联网技术产品经理&#xff0c;国内Top2本科&#xff0c;美国Top10 CS研究生&#xff0c;MBA。我坚信AI是普通人变强的“外挂”&#xff0c;所以创建了“AI信息Gap”这个公众号&#xff0c;专注于分享AI全维度知识…
阅读更多...
第一代高通S7和S7 Pro音频平台：超旗舰性能，全面革新音频体验

第一代高通S7和S7 Pro音频平台：超旗舰性能，全面革新音频体验

以下文章来源于高通中国 如今&#xff0c;音频内容与形式日渐丰富&#xff0c;可满足人们放松心情、提升自我、获取资讯等需求。得益于手机、手表、耳机、车载音箱等智能设备的广泛应用&#xff0c;音频内容可以更快速触达用户。从《音频产品使用现状调研报告2023》中发现&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023