[Flink] Flink On Yarn（yarn-session.sh）启动错误
在Flink上启动 yarn-session.sh时出现 The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in
kafka常用命令
【代码】kafka常用命令。
【数据仓库】FineBI数据可视化使用体验
【数据仓库】FineBI数据可视化使用体验
你在项目中是如何使用kafka的？
较少的分区数可能会限制并行性能，而较多的分区数可能会增加系统管理的复杂性。较少的分区数可能会导致消息处理能力不足，而较多的分区数则会增加系统的管理复杂性。通过合理设置分区数、优化生产者端性能和进行消费者组管理，可以充分发挥Kafka的优势，并构建可靠的消息传递系统。另一方面，如果订单数据的有序性对业
ODPS是什么，阿里云ODPS前世今生
ODPS（OpenDataPlatformandService）是阿里云自研的一体化大数据智能计算平台，10余年来持续迭代，提供了实时离线一体、流批一体、湖仓一体、大数据+AI一体的多场景能力，是业界少有的完全自主研发，支持10万级服务器并行计算、百万级CPU可扩展大数据智能计算平台。
Zookeeper的应用场景
我们使用getChildren方法来获取队列中的第一个消息，并使用getData方法来获取消息的内容。在每个循环迭代中，我们使用dequeue方法来获取队列中的第一个消息，并打印出消息的内容。当队列为空时，我们跳出循环并结束程序。分布式队列通常采用先进先出（FIFO）的方式实现，即每个消息都会被依次
Kafka入门到精通
buffer.memory它代表缓冲区内存的大小，默认为32M，batch.size代表消息批次的大小，默认为16kb，在BufferPool中，batch.size其实就是代表一个ByteBuffer的大小，因为BufferPool只管理batch.size大小的ByteBuffer，在kafka
hive on spark亲自编译，详细教程
编译的spark目录下面的jars文件全部copy到hive/lib下面，将所有的hive/lib jar上传到hdfs目录:hdfs://master:9000/spark-jars/。2、下载spark-2.0.0的源码. https://archive.apache.org/dist/spar
3.精通RabbitMQ—消息队列、RabbitMQ
RabbitMQ整体上是一个生产者与消费者模型，主要负责接收、存储和转发消息。支持多种消息传递模式，如点对点发布/订阅等。消息中间件是一种解决应用程序之间通信问题的技术，它将应用程序解耦，并提供了可靠性、灵活性和可扩展性等优点。
大数据-玩转数据-FLINK-从kafka消费数据
运行本段代码，等待kafka产生数据进行消费。
【Kafka】Kafka consumer lag 为负数
最近对Kafka 集群部署了监控，并集成了granfana图标展示。发现有时候为负数。于是进行一番查询，并总结整理下。
Kafka消息监控管理工具Offset Explorer的使用教程
Offset Explorer是一款用于监控和管理Apache Kafka集群中消费者组偏移量的开源工具。它提供了一个简单直观的用户界面，用于查看和管理Kafka消费者组偏移量的详细信息。
Eureka增加账号密码认证登录
注册中心Eureka在微服务开发中经常使用到，用来管理发布的微服务，供前端或者外部调用。但是如果放到生产环境，我们直接通过URL访问的话，这显然是不安全的。
中间件上云部署 zookeeper
kubectl drain 操作时遵循PDB对象的设定，如果在该节点上运行了属于统一服务的多个pod，则为了保证最少存活数量，系统会确保每终止一个pod就会在健康的node上启动新的pod后，再继续终止下一个pod容器。1、 MinAvailable参数：表示最小可用POD数，表示应用POD集群处
【大数据系列之MySQL】（二十五）：MySQL中的子查询
子查询：出现在其它语句内部的select语句，称为子查询或内查询，就是嵌套的查询结果集。
Window10 系统 RabbitMQ的安装和简单使用
Window10 系统 RabbitMQ的安装和简单使用
Windows下安装HBase
HBase（Hadoop Database），是一个高可靠性、高性能、面向列、可伸缩的分布式存储系统。利用HBase技术可在廉价PC Server上搭建起大规模结构化存储集群。
RabbitMQ消息拒绝怎么解决
RabbitMQ是一个可靠的、高效的、易于使用的分布式消息队列系统。它支持多种消息协议，如AMQP、STOMP、MQTT等。RabbitMQ被广泛应用于企业级应用中，尤其是在异步通信、解耦合和负载均衡方面。在使用RabbitMQ时，有时候我们会遇到消息被拒绝的情况。这种情况不仅会影响系统的正常运行，
rabbitmq开启后台管理页面、创建用户及授权
rabbitmq开启后台管理页面、创建用户及授权
ElasticSearch 管理界面以及常用的命令
进入kibana，点击Dev Tools，此处可以编写es的查询语句；点击Management可以进入index的管理界面。
