搭建大型分布式服务（四十）SpringBoot 整合多个kafka数据源-支持生产者
本插件稳定运行上百个kafka项目，每天处理上亿级的数据的精简小插件，快速上手。< dependency > < groupId > io.github.vipjoey < artifactId > multi-kafka-starter < version > 最新版本号
如何用sql在1分钟从1T数据中精准定位查询？Hive离线数仓 Spark分析
在大数据-Hadoop体系中 ，spark批处理和hive离线数仓可以说是对立并行的两个大分支技术栈，，，建议主攻其一，另一个灵活使用就行。他们是2015出现在国内，2017年之后国外各大公司纷纷采用，国内2020采用的，目前属于很前沿，并且很主流，很顶层的技术。（注：19年国内云计算开始起势，大数
Eureka 学习笔记（2）加载eureka-server.properties中的配置
我们点开 EurekaServerConfig 可以看到EurekaServerConfig，这是个接口，这里面有一堆getXXX()的方法，包含了eureka server需要使用的所有的配置，都可以通过这个接口来获取针对配置定义了一个接口，接口里通过方法暴露了大量的配置项获取的方法，我们可以通过
毕业设计 大数据电商用户行为分析及可视化(源码+论文)
今天学长向大家介绍一个机器视觉的毕设项目，大数据电商用户行为分析及可视化(源码+论文)毕业设计 基于大数据淘宝用户行为分析。
Kafka基础入门篇（深度好文）
Kafka 作为一个高吞吐量的分布式的基于发布/订阅模式的消息队列（Message Queue）被广泛应用，本篇文章将为大家全面的介绍Kafka的基本架构演变和各个组件的基本信息。
Flink-DataWorks第四部分：数据同步（第60天）
本文主要详解了DataWorks的数据同步，为第四部分：由于篇幅过长，分章节进行发布。后续： 数据开发。
【kafka】可视化工具cmak（原kafka-manager）安装&问题解决
众所周知（反正不管你知不知道），kafka-maneger更名了，现在叫cmak！原因是什么呢？据不可靠小道信息说，原kafka-manager这个名字涉及到kafka商标使用问题，应该是被律师函警告了，所以就换名了～
探索大数据的桥梁：阿里云MaxCompute数据采集器
探索大数据的桥梁：阿里云MaxCompute数据采集器 aliyun-maxcompute-data-collectors项目地址:https://gitcode.com/gh_mirrors/al/aliyun-maxcompute-data-collectors 在大数据时代，高效地管理和迁移数
Docker服务器上部署最新版Kafka
Docker服务器上部署最新版Kafka
微服务实战系列之玩转Docker（五）
是骡子是马拉出来遛遛”。目的是看一个人/物是不是名副其实。我们在使用docker时，也要看看它究竟是如何RUN起来的。当面试官问你的时候，可以如是回答，保你“一文通关”。今天博主继续分享新篇，助你一文读懂docker run，各位准备好“小板凳”了么？（此处适合三连一波）docker run是doc
毕业设计 大数据招聘租房可视化系统（源码+论文）
🔥这两年开始毕业设计和毕业答辩的要求和难度不断提升，传统的毕设题目缺少创新和亮点，往往达不到毕业答辩的要求，这两年不断有学弟学妹告诉学长自己做的项目系统达不到老师的要求。为了大家能够顺利以及最少的精力通过毕设，学长分享优质毕业设计项目，今天要分享的是🚩毕业设计 大数据招聘租房可视化系统（源码+论
Kafka的工作流程
消息生产: 生产者将消息发送到Kafka集群，并选择目标分区。消息存储: Broker将消息持久化到磁盘，并通过副本机制保证数据的高可用性和容错性。消息消费: 消费者从Kafka集群拉取消息，并处理消息。消费者定期提交消费进度，以确保消息的准确处理和故障恢复。通过理解Kafka的工作流程，可以更好地
Eureka心跳调优：客户端心跳间隔配置全攻略
在微服务架构中，服务发现是确保服务间有效通信的关键。Eureka作为Netflix开源的服务发现框架，提供了服务注册与发现的功能。Eureka Client作为客户端组件，需要定期向Eureka Server发送心跳以续约，表明自己的存活状态。本文将详细探讨如何配置Eureka Client的心跳间
Flink SQL整理
Flink SQL整理
消息中间件比较：Redis,Kafka和RabbitMQ
对微服务使用时，通常使用消息代理。代理确保不同微服务之间的通信可靠且稳定，消息在系统内得到管理和监控，并且消息不会丢失。您可以从几个消息代理中进行选择，它们的规模和数据功能各不相同。这篇博文将比较三种最受欢迎的代理：RabbitMQ、Kafka 和 Redis。
Kafka 实战 - Kafka 的备份机制
Apache Kafka 提供了一种基于副本（Replication）的备份机制，以确保数据的高可用性和容错能力。
RabbitMQ消费者消费消息失败处理
在我们开发分布式系统的过程中，RabbitMQ这样的消息队列无疑是实现微服务间通信的利器。然而，消息处理失败在所难免。当我们面临消费消息失败的情况时，该如何应对呢？在这篇博客中，我将带你深入探讨RabbitMQ消费者的消息失败处理策略。
k8s中部署hive，包括客户端及服务端
推送好之后，在cube studio平台上，新建一个pipeline，使用自定义镜像模板，填写镜像为ccr.ccs.tencentyun.com/cube-studio/hadoop-hive:v3.3.2-3.1.3，debug，检查目录对不对，检查环境变量是否正确，在命令行输入hive命令，看是
黑马头条微服务学习day6-kafka及异步通知文章上下架
（1）创建kafka-demo项目，导入依赖</</</（2）生产者发送消息import org/*** 生产者//1.kafka的配置信息 Properties properties = new Properties();//kafka的连接地址 properties . put(Producer
kafka生产者性能相关的参数理解
一个消息发送后在得到服务端响应之前，生产者还可以发送的消息条数，配合retries使用，可以保证消息的顺序性，假设有两条消息A、B，A先发送但失败了在执行重试时，B发送且成功了，之后A也重试成功了，此时A、B消息顺序就反了，如果将此参数设置为1，则可以保证A在重试时，B消息无法进行发送，必须等A收到
