RabbitMQ学习实践一：MQ的安装
文章是本人在学习springboot实现消息队列功能时所经历的过程的记录，仅供参考，如有侵权请随时指出。
Pyspark环境配置（Anaconda3）--保姆级教程
本文章主要帮助读者在 Windows 操作系统上搭建单机模式的 PySpark 开发环境.本次环境安装包括：JDK-1.8+jre-1.8+Mysql-8.0+Anaconda3(2022.10)+hadoop-3.2.2+hive-3.1.1
Databend：下一代云数据仓库解决方案
Databend是一个用Rust语言开发的开源云数据仓库,旨在为大规模数据分析提供高性能、低成本的解决方案。作为Snowflake的替代品,Databend专注于快速查询执行和数据摄取,适用于复杂的大规模数据集分析。云原生架构: 与AWS S3、Azure Blob、Google Cloud等云存储
基于Hadoop的天气预报数据爬取与可视化分析（爬虫 + 可视化大屏）
💛博主介绍：作为一位计算机老学长和全栈开发人员🎉，我专注于Java、小程序/APP、python、大数据等技术领域，致力于大学生毕业程序、实践项目的开发、指导和咨询。凭借丰富的开发经验和深入的技术解析，我在此分享实用的编程资源、源代码，并提供定制化技术咨询💡。我的目标是让技术学习变得更高效、更
Python知识点：如何使用Flink与Python进行实时数据处理
通过使用PyFlink，Python开发者可以利用Flink的强大功能来构建实时数据处理应用。无论是简单的数据转换还是复杂的流处理任务，Flink与Python的集成都能提供强大的支持。随着技术的发展，Flink和Python都在不断地引入新的特性和算法，以提高数据处理的效率和准确性。PyFlink
Hive数仓操作（十七）
一、Hive 四种存储格式在 Hive 中，支持四种主要的数据存储格式，每种格式有其特点和适用场景，不过一般只会使用Text 和 ORC 二、Hive 行列存储三、Hive 压缩格式1. TEXTFILE压缩算法：可使用 Gzip、Bzip2 等压缩算法。四、Hive 建表手册创建表的基本语法
Kafka与RabbitMQ：深入理解两者之间的区别
在现代分布式系统架构中，消息队列作为异步通信的重要手段，扮演着至关重要的角色。Apache Kafka和RabbitMQ作为两大主流消息队列系统，各自具有独特的设计理念和优势。本文将深入探讨Kafka与RabbitMQ之间的主要区别，帮助读者在选择时做出更明智的决策。
python学习-python对kafka的相关操作
Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写，用于处理实时数据流。它以高吞吐量、低延迟和可扩展性等特点而著称，广泛应用于Web数据抓取、日志收集、消息系统等领域。Kafka的主要特点包括：1. 高吞吐量：Kafka能够处理大规模的数据流，每秒可以处理几
Kafka REST Proxy 使用教程
Kafka REST Proxy 使用教程 kafka-rest kafka-rest: 提供了一个RESTful接口来与Kafka集群交互，方便进行数据生产和消费，以及执行管理操作。
毕设项目 大数据招聘租房可视化系统（源码+论文）
🔥这两年开始毕业设计和毕业答辩的要求和难度不断提升，传统的毕设题目缺少创新和亮点，往往达不到毕业答辩的要求，这两年不断有学弟学妹告诉学长自己做的项目系统达不到老师的要求。为了大家能够顺利以及最少的精力通过毕设，学长分享优质毕业设计项目，今天要分享的是🚩毕业设计 大数据招聘租房可视化系统（源码+论
kafka动态认证 自定义认证 安全认证-亲测成功
Kafka默认是没有安全机制的，一直在裸奔。用户认证功能，是一个成熟组件不可或缺的功能。在0.9版本以前kafka是没有用户认证模块的（或者说只有SSL），好在kafka0.9版本以后逐渐发布了多种用户认证功能，弥补了这一缺陷（这里仅介绍SASL），认证机制是SASL/PLAIN。kafka的用户认
Java使用RabbitMQ如何保证消息幂等性
在Java中使用RabbitMQ时，保证消息处理的幂等性至关重要。幂等性意味着即使同一消息被处理多次，处理的结果也是一致的。消息重复处理在分布式系统中是一个常见问题，可能由于网络抖动、消费者重启、消息重复投递等原因导致。因此，设计幂等的消息处理机制可以避免数据的重复操作、状态的不一致等问题。
大数据-171 Elasticsearch ES-Head 与 Kibana 配置 使用 测试
Kibana是一个基于Node.js的Elasticsearch索引库数据统计工具，可以利用Elasticsearch的聚合功能，生成各种图标，如柱形图、线状图、饼图等。而且还提供了操作Elasticsearch索引数据的控制台，并且提供了一定的API提示，非常有利于我们学习Elasticsearc
如何解决MQ的重复消费问题？Kafka、ActiveMQ、RabbitMQ有什么区别？
如何解决MQ的重复消费问题？MQ（消息队列）的重复消费问题是一个需要认真对待的挑战，因为它可能导致业务逻辑的重复执行，进而引发数据不一致或其他问题。
实战教程！Zabbix 监控 Spark 中间件配置教程
JMX（Java Management Extensions）作为Java平台标准的一部分，提供了一种标准化的机制，用于监控和管理应用程序、系统对象、设备和服务。JMX具有跨平台、灵活性强、监控能力强、易于集成与扩展、图形化界面支持以及安全性与可配置性等多方面的优势，是监控Spark等复杂Java应
RabbitMQ普通集群部署+镜像
第二个地方就是/var/lib/rabbitmq/.erlang.cookie。各节点是通过⼀个magic cookie来实现的,这个cookie存放在/var/lib/rabbitmq/.erlang.cookie中，⽂件是400的权限。在RabbitMQ集群集群中，必须⾄少有⼀个磁盘节点，否则队
【黑马点评】 使用RabbitMQ实现消息队列——2.使用RabbitMQ监听秒杀下单
黑马点评之使用RabbitMQ实现消息队列
Eureka原理实践
随着互联网技术的发展，微服务架构逐渐成为企业级应用开发的主流选择。与传统的单体架构相比，微服务架构具有更高的灵活性和可扩展性。然而，微服务架构也带来了一些新的挑战，其中之一就是服务注册与发现的问题。Eureka作为Netflix开源的服务注册与发现组件，在微服务架构中扮演着至关重要的角色。通过这篇文
kafka查看topic的偏移量
1. 列举消费者2. 查看偏移量3. 移动至最新。
基于 MySQL + Spark + Echarts + SpringBoot的豆瓣电影数据可视化项目
本项目成功实现了基于 MySQL + Spark + Echarts + Spring Boot 的豆瓣电影数据可视化，为电影爱好者、研究者和从业者提供了有价值的数据分析和可视化工具。未来，可以进一步扩展数据来源和分析维度，提高数据的准确性和完整性，同时优化可视化效果，提供更加丰富和交互性强的用户体
