三.Kafka入门到精通-SpringBoot整合Kafka(同步&异步消息&事务消息&手动确认)
前面两个章节我们把Kafka给安装起来然后使用命令演示是生产和消费的过程,以及Kafka的架构原理,接下来就是Kafka的实战使用,顺应如今企业流行的开发模式,当然要使用SpringBoot和Kafka进行整合。第一步:我们基于SpringBoot来快速入门Kafka,我这里使用的SpringBoo
kafka一致性保证
介绍了kafka的一致性
RabbitMQwindows和LInux下载安装详细流程
MQ 介绍,是基础数据结构中“先进先出”的一种数据结构。一般用来解决应用解耦,异步消息,流量削峰等问题,实现高性能,高可用,可伸缩和最终一致性架构。
线性时间选择算法-《数据结构》(结合例题讲解)
题目:给定一个包含n个元素的一维线性序列a[p:r],从这n个元素中找出第k小的元素,1
DolphinScheduler——流程调度工具
一、平台简介Apache DolphinScheduler(目前处在孵化阶段)是一个分布式、去中心化、易扩展的可视化DAG工作流任务调度系统,其致力于解决数据处理流程中错综复杂的依赖关系,使易于使用,开发人员可以通过非常简单的拖拽操作构建ETL过程。不仅对于ETL开发人员,无法编写代码的人也可以使用
RabbitMQ-交换机类型
RabbitMQ的交换机类型
强推!30个遥感数据下载网站整理分享
账号注册,直接下载即可。INPE是由中国与巴西合作支持,主要数据源自中巴合作项目,两颗资源卫星CBERS-2和CBERS-2b,也收录了CBERS、Landsat,、ResourceSat、S-NPP、Terra & UK-DMC 2等项目的数据,但所包含数据仅局限在南美以及非洲地区。数据资源更新比
【SQL开发实战技巧】系列(三十三):数仓报表场景☞从不固定位置提取字符串的元素以及搜索满足字母在前数字在后等条件的数据
本篇文章讲解的主要内容是:***通过需求:从不固定位置提取字符串的元素,要求取出方括号中对应的字符串,分三列显示。给大家介绍regexp_substr正则表达式日常工作中的巧妙用法。通过需求:搜索同时包含字母数字混合的字符串,要求返回T中既包含字母,又包含数字的行。那么只要其中有"字母在前,数字在后
ubuntu安装kafka
ubuntu kafka
Hive正则表达式
Hive正则表达式
大数据 MapReduce编程实践(1)编程实现文件合并和去重操作
标题提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档文章目录一、实验目的二、实验平台三. 实验内容和要求(1)编程实现文件合并和去重操作(2)编写程序实现对输入文件的排序(3)对给定的表格进行信息挖掘四、实验遇到的问题一、实验目的1.通过实验掌握基本的MapReduce编程方法;2.
原理实践,全面讲解Logstash+Kibana+kafka
Logstash是一款轻量级的日志搜集处理框架,可以方便的把分散的、多样化的日志搜集起来,并进行自定义的处理,然后传输到指定的位置,比如某个服务器或者文件。而在官网,对于Logstash的介绍更是完整,我这里就展示一下官网的介绍输入:采集各种样式、大小和来源的数据过滤器:实时解析和转换数据输出:选择
Hadoop3.2.4+Hive3.1.2+sqoop1.4.7安装部署
Hive:Hadoop3.2.4+Hive3.1.2+sqoop1.4.7安装部署
【SQL开发实战技巧】系列(二十四):数仓报表场景☞通过执行计划详解”行转列”,”列转行”是如何实现的
本篇文章讲解的主要内容是:***目前Oracle支持的行列互换有两种方式:case when、pivot\unpivot,我将通过几个案例来给大家详解如何通过这两种方式实现“行转列”,“列转行”的需求,并通过执行计划看case when、pivot\unpivot二者的底层逻辑关系以及效率上的影响。
Elasticsearch深入理解(十五)——并发写入导致版本冲突解决方案
数据同步中,在使用阿里云Elasticsearch7.10.0版本的集群作为目标数据源时,在连续写入同一文档(document)出现版本冲突问题。
Spark系列之SparkSubmit提交任务到YARN
Spark系列之SparkSubmit提交任务到YARN
【若依】框架:第01讲前后端分离项目
本身是一个优秀的简单的后台管理系统框架,前端(Vue,ElementUI),后端(Spring Boot、Spring Security、Redis & Jwt),本身可以直接拉下来直接使用.它的强大之处在于代码自动生成器的使用,可以根据数据库的表对应生成全套前后端代码,代码植入后可以直接使用,复杂
利用GEE计算城市遥感生态指数(RSEI)——Landsat 8为例
GEE,RSEI,城市生态状况快速监测与评价
Hadoop上传文件到hdfs中
找到dfs.permissions属性修改为false(默认为true)OK了。
RabbitMQ系列【15】AmqpAdmin使用详解
在之前,我们都是通过注入Bean的方式去声明交换机、队列,应用启动时去自动创建。如果需要动态创建,比如通过接口、或者业务代码自己去操作,这个使用就需要使用RabbitMQ提供的操作接口。如果是基于,则可以直接使用其提供的AmqpAdmin,其对RabbitMQ的原生接口进行了二次封装,使用起来十分方