Apache-Flink未授权访问高危漏洞修复
由于flink没有鉴权的设置，使用使用 htpasswd 工具+服务器系统防火墙设置，才能禁用默认对外访问的8081端口，使用用户名+密码实现安全验证登录flink web ui。
Kafka 安装教程和基本操作
Kafka安装教程和基本操作
Kafka篇
还有按照大小log.retention.bytes来删除的，比如设置所有日志最大为8T，此时满了，就会把最早的给删除了。压缩：log.cleanup.policy=compact。压缩方法：对于相同的key，不同的value，保留最新的value。
spark如何搭建本地模式
1、获取spark和Hadoop、scala的对应安装包，注意版本间一定要匹配，否则无法使用使用，本次学习使用的事scala2.12.11、hadoop3.0.0、spark-3.0.0-bin-hadoop3.2。3、跟着【spark本地安装辅助教程】安装，注意教程的内容不是全部适用、hadoop
设置zookeeper的clientPortAddress参数
同时，这样的配置是必要的，如果你需要从网络架构上限制ZooKeeper监听的网络接口，例如在某些接口是面向公网，而ZooKeeper应该只在内网工作的情况下。在有一个由3台服务器组成的ZooKeeper集群的情况下，每台服务器的clientPortAddress应该设置为对应服务器的IP地址。这样的
RabbitMQ快速入门
RabbitMQ是一款成熟可靠的消息中间件，现在已经被全世界几亿用户使用。RabbitMQ支持了多个开放的标准协议，不同系统、语言可以按照这个协议进行消息传递和交互。RabbitMQ本身是使用Erlang语言写的，但提供了其他各种语言版本：Python、Java、Go........RabbitMQ
Spark---核心概念（Spark,RDD,Spark的核心构成组件）详解
Spark就是一个集成离线计算，实时计算，SQL查询，机器学习，图计算为一体的通用的计算框架。何为RDD？其实RDD就是一个不可变的scala的并行集合。Spark的核心概念就是RDD，指的是一个不可变、可分区、里面元素可并行计算的集合，这个数据的全部或者部分可以缓存在内存中，在多次计算间被重用。
Kafka 3.x.x 入门到精通（04）——对标尚硅谷Kafka教程
Kafka是一个由Scala和Java语言开发的，经典高吞吐量的分布式消息发布和订阅系统，也是大数据技术领域中用作数据交换的核心组件之一。以高吞吐，低延迟，高伸缩，高可靠性，高并发，且社区活跃度高等特性，从而备受广大技术组织的喜爱。
Flink 窗口触发器(Trigger)(一)
Flink的窗口触发器（Trigger）是流处理中一个非常关键的概念，它定义了窗口何时被触发并决定触发后的行为（如进行窗口数据的计算或清理）。
Hadoop 面试题（十一）
1. 简述Hadoop-2.6.5 集群中，HDFS 默认副本块（含原数据块）的个数是 ？2. Google三驾马车是Hadoop等分布式系统的基石，其中论文()不属于三驾马车之一 ？3. 简述关于安全模式命令，正确的是 ？4. 简述以下不属于Hadoop中NameNode的功能点的选项是 ？5.
大数据HDFS概述【长期更新】
Hadoop基本介绍和设计原理
【Hive SQL】时间戳格式化、时间字符串转换格式化、时区切换（Mysql\Hive SQL\Athena）
本文主要记录 [Mysql\ Hive SQL\ Athena] 时间戳转换、日期格式化、时区转换各种数据数据操作
【RabbitMQ实战】Springboot 整合RabbitMQ组件，多种编码示例，带你实践 看完这一篇就够了
该篇文章内容较多，包括有RabbitMQ一些理论介绍，provider消息推送实例，consumer消息消费实例，Direct、Topic、Fanout多种交换机的使用，同时简单介绍对消息回调、手动确认等。例如：随着人工智能的不断发展，机器学习这门技术也越来越重要，很多人都开启了学习机器学习，本文就
如何安装和管理RabbitMQ
将事情推迟一段时间而不是立即去做，可能被认为是懒惰的。事实上，大多数情况下可能确实如此。然而，有时候这样做绝对是正确的。偶尔，需要将耗时的工作推迟一段时间；它需要被排队以便将来执行，以便处理更重要的事情。为了实现这一点，你需要一个代理：一个接受来自各种发送方（例如 Web 应用程序）的消息（例如作业
k8s学习--k8s集群部署kafka详细过程
Kafka 是一个由 Apache 软件基金会开发的分布式流处理平台，主要用于实时数据流的处理和传输。它最初由 LinkedIn 开发，并于 2011 年开源。### kafka主要特点1高吞吐量： Kafka 能够处理大量的数据流，适用于需要高吞吐量的场景。2.分布式：Kafka 具有分布式架构，
【分布式技术】消息队列Kafka
Kafka 是一个分布式的基于发布/订阅模式的消息队列（MQ，Message Queue），主要应用于大数据领域的实时计算以及日志收集。（2）Kafka 简介。
Java版Flink使用指南——自定义无界流生成器
新建src/main/java/org/example/generator/UnBoundedStreamGenerator.java然后UnBoundedStreamGenerator实现RichSourceFunction接口主要实现SourceFunction接口的run和cancel方法。r
【高级应用篇】深入Spring Boot与RabbitMQ：构建可靠的微服务通信
在微服务架构中，消息队列作为异步通信与服务解耦的关键组件，发挥着不可替代的作用。本文详尽探索RabbitMQ的高级特性，包括消息确认、持久化、优先级、死信队列、TTL以及发布确认机制，展示如何利用这些特性增强Spring Boot应用与RabbitMQ的集成，实现更高效、更稳健的微服务通信。通过讲解
SpringCloud微服务实践1|Eureka实践，nacos实践，Ribbon实践
通过IRule接口 选择某个服务实例----IRule接口的实现类，是不同的负载均衡策略。通过修改其参数可以实现不同的策略ribbon:NFLoadBalancerRuleClassName: com.alibaba.cloud.nacos.ribbon.NacosRule # 负载均衡规则。
RabbitMQ发布确认及交换机类型
当生产者（Producer）启用发布确认功能后，每次发送消息到RabbitMQ时，都会获得一个唯一的序列号（delivery tag），并从1开始递增。一旦消息被成功路由到至少一个匹配的队列，并且满足持久化条件（如果已配置），RabbitMQ会向生产者发送一个包含已确认消息序列号的basic.ack
