RabbitMQ:可靠消息传递的强大消息中间件
RabbitMQ详细介绍
后端面试话术集锦第五篇:rabbitmq面试话术
后端面试话术集锦第四篇:rabbitmq面试话术。介绍下rabbitmq;如何保证消息确定消息发送成功,并且被消费成功,有什么保障措施;如何保证消息不被重复消费;RabbitMQ宕机了怎么处理。rabbitmq消息发送失败了怎么办,或者如何保证消息可靠传输;rabbitmq消息发送失败了怎么办,或者
Strimzi从入门到精通系列之三:部署Kafka Connect
Kafka Connect 是一个用于在 Apache Kafka 和其他系统之间传输数据的工具。例如,Kafka Connect 可能会将 Kafka 与外部数据库或存储和消息传递系统集成。在Strimzi中,Kafka Connect以分布式方式部署。Kafka Connect 也可以在独立模式
Zookeeper的使用
分布式协调框架,小型的树形结构数据共享储存系统。zookeeper的应用场景集群管理注册中心配置中心发布者将数据发布到ZooKeeper一系列节点上面,订阅者进行数据订阅,当数据有变化时,可及时得到数据的变化通知。数据的发布/订阅分布式锁分布式队列负载均衡负载均衡是通过负载均衡算法,客户端负载均衡。
大数据的前世今生与未来
大数据的前世今生与未来
hive表的全关联full join用法
把两个表的结果拼在一行了,匹配不上的都用NULL值进行填充了,显然不是我要的结果。查询完显示如下,nice,😄。test_b表的数据如下;test_a表的数据如下。
Flink自定义触发器
Apache Flink是一个流处理框架,它提供了许多内置的触发器来控制流处理作业的执行。但是,有时候内置的触发器不能满足我们的需求,这时候我们就需要自定义触发器
flink+kafka+doris+springboot集成例子
1、springboot基于netty编写接收程序。
【Hadoop-Distcp】工具简介及参数说明
【Hadoop-Distcp】工具简介及参数说明
zookeeper入门学习
zk体系化学习
kafka学习-基本概念与简单实战
生产者主要有KafkaProducer和ProducerRecord两个对象:KafkaProducer用于发送消息,ProducerRecord用于封装kafka消息。生产者生产消息后,需要broker的确认,可以选择同步或者异步确认:同步确认效率低;异步确认效率高,但需要设置回调对象。消费者主要
DAMA数据管理知识体系-数据治理工程师(CDGA)
本专栏为数据治理专栏,里面的内容主要是本人参加数据治理考试(CDGA)前做的笔记,包括一些考题或者易错点。其中加粗的文字为考试中常考的。
Springboot与RabbitMQ消息超时时间、队列消息超时时间
TTL是 Time-To-Live 的缩写,RabbitMQ可以对消息和队列设置TTL(过期时间)。RabbitMQ针对队列中的消息过期时间(Time To Live, TTL)有两种方法可以设置。第一种方法是通过队列属性设置,队列中所有消息都有相同的过期时间。第二种方法是对消息进行单独设置,每条消
【Hive】HQL Map 『CRUD | 相关函数』
1. Map 增删改查1.1 声明 Map 数据类型1.2 增1.3 删1.4 改1.5 查2. Map 相关函数2.1 单个Map3. Map 与 String3.1 Map 转 string3.2 string 转 Map
第19届高级数据挖掘与应用国际会议(ADMA‘23)
该会议旨在汇集来自世界各地的数据挖掘专家,并为数据挖掘领域的原创研究成果提供一个领先的国际论坛,包括应用、算法、软件和系统,以及具有潜力的应用领域,如社交网络挖掘、智能交通、金融科技、智能制造、智能手机、生物医学科学、绿色计算等。第19届国际高级数据挖掘和应用会议(ADMA'23)的工业和从业者论文
数据仓库建设实践——如何通过数据仓库建设提升效率并确保数据质量
随着互联网经济的快速发展,全球消费者对汽车的需求越来越旺盛。在全球范围内,公共汽车运营商(PSA)正在竞争激烈,包括美国的Tesla、上海的东风、中国的福特等。全球公共汽车市场规模每年呈现爆炸性增长态势。其中,美国曾经的领先地位已经被中国的车企掌控,新赛道的崛起也给PSA带来巨大的机遇。然而,美国的
hive中collect_list函数
collect_list聚合函数,
5、HDFS API的RESTful风格--WebHDFS
WebHDFS 提供了访问HDFS的RESTful接口,内置组件,默认开启。WebHDFS 使得集群外的客户端可以不用安装HADOOP和JAVA环境就可以对HDFS进行访问,且客户端不受语言限制。当客户端请求某文件时,WebHDFS会将其重定向到该资源所在的datanode。
Flink与Cassandra:如何在大规模数据处理中存储与管理数据
作者:禅与计算机程序设计艺术 11. "Flink与Cassandra:如何在大规模数据处理中存储与管理数据"1. 引言1.1. 背景介绍随着大数据时代的到来
zookeeper/HA集群配置
1.1 安装4台虚拟机(1)按照如下设置准备四台虚拟机,其中三台作为zookeeper,配置每台机器相应的IP,hostname,下载vim,ntpdate配置定时器定时更新时间,psmisc(psmisc用于管理系统上运行进程,包括ps、kill、fuser、pstree等命令它能够更方便地使用