【spark】序列化和反序列化，transient关键字的使用
序列化就是指将一个对象转化为二进制的byte流（注意，不是bit流），然后以文件的方式进行保存或通过网络传输，等待被反序列化读取出来。1）一旦变量被transient修饰，变量将不再是对象持久化的一部分，该变量内容在序列化后无法获得访问。如果在driver端不使用instance，那么@transi
【系统开发】尚硅谷 - 谷粒商城项目笔记（七）：消息队列
4369 – erlang发现口5672 --client端通信口15672 – 管理界面ui端口25672 – server间内部通信口在web浏览器中输入地址：http://服务器ip:15672/输入默认账号: guest : guestoverview：概览：无论生产者还是消费者，都需要与R
ElasticSearch安装
因为ElasticSearch是用Java语言编写的，所以必须安装JDK的环境，并且是JDK 1.8以上。出现上面页面就是安装成功了。
大数据面试题：Kafka怎么保证数据不丢失，不重复？
大数据面试题：Kafka怎么保证数据不丢失，不重复？
详解Nacos和Eureka的区别
Eureka 是Spring Cloud 微服务框架默认的也是推荐的服务注册中心, 由Netflix公司与2012将其开源出来,Eureka基于REST服务开发,主要用于实现AWS云的中服务定位,以实现中间层服务器的负载均衡和故障转移,遵循着CAP理论中的A(可用性)P(分区容错性)一个Eureka
RabbitMq图形界面创建队列操作步骤及控制台使用说明
版本：RabbitMQ 3.9.7控台台访问路径：http://localhost:15672/#/queues（1）输入自定义的队列名称（2）其他输入参数为默认值即可（3）点击【Add queue】创建队列成功登录后，您将看到 RabbitMQ 的控制台界面。该界面将显示以下几个主要部分：Over
jps查看命令缺少resourcemanager和nodemanager怎么处理
缺少resourcemanager和nodemanager怎么处理(最实用的解决方案）
@RabbitListener 消息队列 消息序列化
在一些场景下我们希望在消息发送到MQ之前或者接受消息前对消息做一些自定义处理,这个时候就需要自定义MessageConverter了。
HDFS基本命令
HDFS基本命令
【大数据】Flink 详解（七）：源码篇 Ⅱ
调度器是 Flink 作业执行的核心组件，管理作业执行的所有相关过程，包括 JobGraph 到 ExecutionGraph 的转换、作业生命周期管理（作业的发布、取消、停止）、作业的 Task 生命周期管理（Task 的发布、取消、停止）、资源申请与释放、作业和 Task 的 Faillover
Kafka-配置Kerberos安全认证(JDK8、JDK11)
从 Kerberos 服务器上拷贝到目标机器 或 找运维人员要一份。从 Kerberos 服务器上拷贝到目标机器 或 找运维人员要一份。3、Kerberos 配置文件（2、keytab 文件（1、JAAS 配置文件。
SpringCloud学习路线（9）——服务异步通讯RabbitMQ
通过Docker容器，拉取RabbitMQ并在虚拟机中启动，在Java项目中配置相关信息，进行连接，这里介绍了五种模型：基础队列、工作队列，广播队列，路由队列，主题队列等等的基本实现思路，以及消息转换器的使用，其中 利用SpringAMQP对Springboot进行整合，采用RabbitTempla
flink入门-流处理
flink入门-流处理
大数据Flink（五十九）：Flink on Yarn的三种部署方式介绍以及注意
如果使用的是flink on yarn方式，想切换回standalone模式的话，需要删除文件：【/tmp/.yarn-properties-root】到这里，我们以 Pre-Job 的方式成功部署了 PyFlink 的作业！但是会话模式的话，如果是kill掉任务，其不会执行自动删除这个文件的步骤，
Hadoop --- HDFS介绍
HDFS 文件存储系统。适合一次写入，多次读出的场景。HDFS不需要单独安装，安装Hadoop的时候带了HDFS系统。
如何控制Flink代码运行时控制日志级别
在Flink程序中，可以通过设置日志级别来控制控制台输出的信息。要让控制台只打印结果信息，可以将日志级别设置为。，并将日志输出到控制台。在这种配置下，控制台将只显示错误信息和。，并将日志输出到控制台。在这种配置下，控制台将只显示错误信息和。的文件（如果已经存在，请修改相应的配置）。要设置日志级别，请
Kafka 整合 SpringBoot
编写测试代码：ApplicationTests.java。
Kafka、RocketMQ、RabbitMQ如何保证消息的顺序消费？
全局有序是一个topic下的所有消息都要保证顺序，如果要保证消息全局顺序消费，可以将该主题的队列数设置为1，牺牲高可用性。局部有序是指保证同一个消息队列上的消息顺序消费。RabbitMQ没有属性设置消息的顺序性，所以在没有前提的情况下说 RabbitMQ消息的消费具有顺序性是错误的。二、生产者在发送
Log4j2 配置日志记录发送到 kafka 中
log4j2 在 2.11.0 之后的版本，已经内置了 KafkaAppender 支持可以将打印的日志直接发送到 kafka 中，在这之前如果想要集中收集应用的日志，就需要自定义一个 Layout 来实现，相对来说还是比较麻烦的。
【博学谷学习记录】超强总结，用心分享|HBase常用的Shell命令
（2）查看HBase的命令帮助文档（9）删除数据: delete 和 deleteAll（10）查看表结构（11）清空表（12）查询多条数据: scan（13）查看表共计有多少条数据2 HBase的高级shell操作（1） HBase的过滤器查询（2）显示HBase当前登录使用用户：whoami（
