大数据处理架构Hadoop
Hadoop是Apache软件基金会旗下的一个开源分布式计算平台，为用户提供了系统底层细节透明的分布式基础架构Hadoop是基于Java语言开发的，具有很好的跨平台特性，并且可以部署在廉价的计算机集群中Hadoop的核心是分布式文件系统HDFS（Hadoop Distributed File Sys
Spark-Core核心算子
Spark-Core中1、数据源获取。2、转换算子。3、行动算子
ChatGPT的功能，优势，以及在生活中的应用
ChatGPT的功能和优势非常多，下面将详细介绍。总之，ChatGPT是一种非常有用和实用的人工智能技术，它可以为用户提供各种服务和建议，帮助用户解决各种问题和疑虑，提高生活质量和效率。2. 个性化服务：ChatGPT可以根据用户的兴趣和需求，提供个性化的服务和建议，让用户感受到更加贴心的关怀。3.
【图解RabbitMQ-2】图解JMS规范与AMQP协议是什么
在上一节中学习了消息队列是什么？以及消息队列的应用场景有哪些？那么实现消息队列的方式有哪些呢？那么本篇文章将对JMS规范、AMQP协议两大消息队列实现方式进行简单介绍。有关于图解JMS规范与AMQP协议是什么到此就结束了。
Flink+StarRocks 实时数据分析新范式
StarRocks 社区技术布道师谢寅，在 Flink Forward Asia 2022 实时湖仓的分享。
30、Flink SQL之SQL 客户端（通过kafka和filesystem的例子介绍了配置文件使用-表、视图等）
SQL 客户端允许用户创建用户自定义的函数来进行 SQL 查询。当前，这些自定义函数仅限于 Java/Scala 编写的类以及 Python 文件。为提供 Java/Scala 的自定义函数，你首先需要实现和编译函数类，该函数继承自 ScalarFunction、 AggregateFunction
分布式 - 消息队列Kafka：Kafka 消费者的消费位移
再考虑一种情况，当有新的消费者加入时，那么必然会有再均衡的动作，对于同一分区而言，它可能在再均衡动作之后分配给新的消费者，如果不持久化保存消费位移，那么这个新的消费者也无法知晓之前的消费位移。如下图，x 表示某一次拉取操作中此分区消息的最大偏移量，假设当前消费者已经消费了 x 位置的消息，那么我们就
rabbitMQ web页面访问
在腾讯云安全组中手动添加5672和15672端口。再重新试一下，应该可以成功。上述指令建立了一个用户名为admin的账户，密码也是admin。如果用户级别为administrator，上述指令无需执行。如果端口已经打开，则检查防火墙是否关闭。如果出现上面的结果，则说明安装成功。如果登录不成功则需要自
Spring Boot+Kafka实战生产级Kafka消费组
Kafka是一个开源分布式消息系统，最初由LinkedIn开发，之后成为Apache项目的一部分。Kafka主要用于大数据实时流处理，具有低延迟、高吞吐量等特点。本文将会从基本概念、术语说明、原理及应用场景三个方面对Kafka进行详细介绍。Kafka作为一个分布式系统，需要配合Zookeeper实现
Zookeeper是什么，它有什么特性与使用场景？
ZooKeeper 是一种分布式协调服务，主要用于解决分布式系统中的数据同步、配置管理、命名服务等问题。它提供了一个树形结构的命名空间（类似于文件系统），并允许用户在该命名空间中创建节点、读取节点数据、监视节点变化等操作。同时，ZooKeeper 还提供了多种机制来保证数据的一致性和可靠性，如事务、
RabbitMQ 26问，基本涵盖了面试官必问的面试题
RabbitMQ是一个消息中间件：它接受并转发消息。你可以把它当做一个快递站点，当你要发送一个包裹时，你把你的包裹放到快递站，快递员最终会把你的快递送到收件人那里，按照这种逻辑RabbitMQ是一个快递站，一个快递员帮你传递快件。RabbitMQ与快递站的主要区别在于，它不处理快件而是接收，存储和转
一站式Flink&Spark平台解决方案——StreamX
是一个完全由国人发起的开源项目。也欢迎大家联系我们，加入到开源项目中来，为中国开源崛起献上一份自己的力量，未来共同向着成为。比较多，两者是有一定区别的，侧重点不同。未来也会写文做一下两者的对比。生态的不断完善，越来越多的企业选择这两款组件，或者其中之一作为离线。流上的开发部署能力与运行监控能力，努力
解析OpenDataPlatform的数据仓库：如何确保数据的准确性和可靠性？
作者：禅与计算机程序设计艺术 1.简介互联网公司在实现业务需求时，一般会选择一种数据源作为基础数据，在数据处理过程需要对基础数据进行清洗、计算等加工操作。这些处理后的结果可以提供给公司内部各个部门、业务线使用，同时也方便了公司将数据用于分析报表或做决策，提高效率
RabbitMQ 教程 | 第3章 客户端开发向导
这篇 RabbitMQ 教程为学习者提供了全面的内容，帮助学习者充分掌握 RabbitMQ 的应用。整篇教程丰富内容详实，适合初学者和有经验的开发者参考学习。
RabbitMQ实习面试题
在 RabbitMQ 中，确保生产者消息正确发布以及确保消费者已经消费是非常重要的任务。
登录RabbitMQ Management时提示不是私密连接问题
rabbitmq登录web管理页面，不是私密连接问题
如何查看Kafka的Topic消费情况
2.10为Scala版本，0.10.0.2.5.3.0为kafka版本。进入kafka安装目录，然后执行以下命令。从某一时间开始消费某一topic。从最开始开始消费某一topic。或者不指定日志输出位置和设置。
大数据(二)：Numpy基础应用详解
切片操作虽然创建了新的数组对象，但是新数组和原数组共享了数组中的数据，简单的说，如果通过新数组对象或原数组对象修改数组中的数据，其实修改的是同一块数据。花式索引和布尔索引也会创建新的数组对象，而且新数组复制了原数组的元素，新数组和原数组并不是共享数据的关系，这一点通过前面讲的数组的。，对于同样的数值
Docker 搭建 zookeeper、kafka 集群
docker 容器部署 kafka 集群
RabbitMq的使用
最近处理访客记录所以，来学习下rabbitMQ。之前同事已经写好了，这里只需要进行消费，后续会逐渐完善。0.介绍0.1交换机（Exchanges）rabbitmq中生产者发送的消息都是发送到交换机，再由交换机推入队列。所以生产者不知道队列去了哪里，就靠Exchage来控制，交换机总共有以下几种类型。
