【消息队列】kafka2.0.0安装(单机)及基本命令 一、安装JDKmkdir -p /home/winner/software cd /home/winner/software/ tar -zxvf jdk-8u333-linux-x64.tar.gz tar -zxvf kafka_2.11-2.0.0.tgz ln -s jdk1.8.0_333 jdk ln -s kafka_2.11-2.0.0 kafka配置环境变量vim / 大数据 2026年02月09日 38 点赞 0 评论 4369 浏览
掌控消息全链路(4)——RabbitMQ/Spring-AMQP高级特性详解之事务与消息分发 🔥我的主页: 九转苍翎 ⭐️个人专栏: 《Java SE》 《Java集合框架系统精讲》 《MySQL高手之路:从基础到高阶》 《计算机网络》 《Java工程师核心能力体系构建》 《RabbitMQ理论与实践》 天行健,君子以自强不息。 大数据 2026年03月14日 56 点赞 0 评论 4380 浏览
Kafka 和 Flink的讲解 一、Kafka:分布式消息队列1. 核心概念 角色:Kafka 是一个分布式、高吞吐量的消息队列(Pub-Sub 模型),用于实时传输数据流。 关键术语: Producer(生产者):发送数据的客户端(如传感器、应用日志)。 Consumer(消费者):接收和处理数据的客户端(如 Flink、Spark)。 Broker 大数据 2025年05月26日 196 点赞 0 评论 4426 浏览
Flink底层原理解析:案例解析(第37天) 系列文章目录一、flink架构 二、Flink底层原理解析 三、Flink应用场景解析 四、fink入门案例解析 文章目录 系列文章目录 前言 一、flink架构 1. 作业管理器(JobManager) 2. 资源管理器(ResourceManager) 3. 任务管理器(TaskManager) 4 大数据 2025年07月27日 33 点赞 0 评论 4439 浏览
VMware平台的Ubuntu部署完全分布式Hadoop环境 前言:此文章是本人初次部署Hadoop的过程记录以及所遇到的问题解决,这篇文章只有实际操作部分,没有理论部分。因本人水平有限,本文难免存在不足的地方,如果您有建议,欢迎留言或私信告知于我,非常感谢。 部分参考网络资料,如有侵权,联系删除。 文章目录 前言 大数据 2025年05月03日 129 点赞 0 评论 4451 浏览
RabbitMQ 客户端 连接、发送、接收处理消息 RabbitMQ 客户端 连接、发送、接收处理消息 一. RabbitMQ 的机制跟 Tcp、Udp、Http 这种还不太一样RabbitMQ 服务,不是像其他服务器一样,负责逻辑处理,然后转发给客户端 而是所有客户端想要向 RabbitMQ服务发送消息, 第一步:创建一个链接 RabbitMQ 服务的连接需要传入 Rabbi 大数据 2026年01月11日 93 点赞 0 评论 4462 浏览
数智读书笔记系列032《统一星型模型--一种敏捷灵活的数据仓库和分析设计方法》 引言在当今数字化时代,数据仓库作为企业数据管理的核心基础设施,承担着整合、存储和提供企业数据的关键角色。随着商业环境的快速变化和业务需求的日益复杂,数据仓库的设计方法也在不断演进,以适应新的挑战和要求。 背景与意义数据仓库领域长期存在着两种主流方法论之争:Bill Inmon提出的自上而下企业级数据仓库方法和Ralph Kimball倡导的自下而上维度建模方法。这两种方法各有优劣,但在应对现代企 大数据 2025年05月20日 62 点赞 0 评论 4494 浏览
MapReduce报错 HADOOP_HOME and hadoop.home.dir are unset. 运行课程讲解内容出现这个报错: 1、在电脑里解压之前发过的Hadoop安装包 2、配置用户变量 3、配置系统变量 4、配置系统Path变量 5、下载链接的两个文件:链接: ?pwd=56tv 提取码: 56tv –来自百度网盘超级会员v7的分享6、放到刚刚解压路 大数据 2025年05月20日 153 点赞 0 评论 4524 浏览
Kafka选举机制深度解析:分布式系统中的民主与效率 Kafka选举机制深度解析:分布式系统中的民主与效率 🌟 你好,我是 励志成为糕手 ! 🌌 在代码的宇宙中,我是那个追逐优雅与性能的星际旅人。 ✨ 每一行代码都是我种下的星光,在逻辑的土壤里生长成璀璨的银河; 🛠️ 每一个算法都是我绘制的星图,指引 大数据 2025年11月24日 70 点赞 0 评论 4528 浏览
Docker安装Kafka(不依赖ZooKeeper) 创建docker-compose.yamlversion: "3.9" #版本号 services: kafka: image: apache/kafka:3.9.0 container_name: kafka hostname: kafka ports: - 9092:9092 # 容器内部之间使用的监听端口 - 9 大数据 2025年08月06日 197 点赞 0 评论 4529 浏览