Flink流批一体计算（11）：PyFlink Tabel API之TableEnvironment
编写 Flink Python Table API 程序的第一步是创建 TableEnvironment。这是 Python Table API 作业的入口类。get_config()返回 table config，可以通过 table config 来定义 Table API 的运行时行为。
Flink TableAPI 依赖问题
Flink TableAPI 依赖问题。“Could not instantiate the executor. Make sure a planner module is on the classpath”
Mven安装配置、配置国内镜像，jdk17版本、配置maven环境变量
Mven安装配置、配置国内镜像，jdk17版本、配置maven环境变量
Windows操纵kafka
【代码】Windows操纵kafka。
关于kafka消费者超时配置
1. 在 Spring Boot 的配置文件（如 `application.properties` 或 `application.yml`）中添加 Kafka 消费者相关的配置项。在上述示例中，`spring.kafka.consumer.properties.max.poll.interval.m
ZooKeeper的集群部署和启动与关闭
分别在虚拟机Spark01、Spark02和Spark03 的/export/data/zookeeper/zkdata目录中创建myid文件，在虚拟机Spark01的myid文件中写入值1，在虚拟机Spark02的myid文件中写入值2，在虚拟机Spark03的myid文件中写入值3。”命令编辑Z
flink cdc报错
执行flink cdc 报错，ClassNotFoundException: org.apache.kafka.common.utils.ThreadUtils
【RabbitMQ笔记10】消息队列RabbitMQ之死信队列的介绍
在RabbitMQ中，并没有提供真正意义上的延迟队列，但是RabbitMQ可以设置队列、消息的过期时间，当队列或者消息到达过期时间之后，还没有被消费者消费，那么RabbitMQ会将这些消息放入另外一个队列，这个队列叫做：死信队列，而这个过期的消息就叫做：死信消息。哪些情况下，消息会变成死信消息？？？
【项目实战】Kafka 重平衡 Consumer Group Rebalance 机制
Kafka重平衡是指Apache Kafka分布式消息系统中的一个过程。在Kafka中，消息被分区并分布在不同的主题中的多个分区中。每个消费者组可以订阅一个或多个主题，并从分区中消费消息。当消费者加入或离开消费者组时，或者主题的分区数量发生变化时，Kafka会触发重平衡过程。重平衡的目的是重新分配分
【项目实战】Kafka 的 Leader 选举和负载均衡
Kafka的Leader选举和负载均衡是保证高可用性、故障恢复、负载均衡和性能优化的重要机制。它们能够确保Kafka集群的稳定运行和高效处理大量数据的能力
Flink 学习三 Flink 流 & process function API
基础流操作,以及相关的processFunction基础概念和使用
Kafka系列之：连接器客户端配置覆盖策略
虽然最初的提案允许覆盖源连接器和接收器连接器，但它在允许连接器的不同配置方面仍然受到限制。在较高层面上，该提案旨在引入类似于 Core Kafka 中可用的 CreateTopicPolicy 的可配置策略，用于连接器客户端配置覆盖。更具体地说，我们将引入一个新的工作配置，该配置将允许管理员配置连接
【flume 配置详解】
在上面的配置中，我们可以看到agent1.sources、agent1.channels和agent1.sinks这些属性，它们分别对应了源、通道和目标组件的配置，而agent1.sources.source1.type、agent1.sources.source1.command、agent1.c
大数据下的竞彩足球胜平负分析技巧1
什么是有效的数据支撑？这里指的是某种条件/组合条件下的准确率，比如70%以上、80%以上。
[Spring Boot]12 ElasticSearch实现分词搜索功能
我们在使用搜索功能的时候，有时，为了使搜索的结果更多更广，比如搜索字符串“领导力”，希望有这些组合的结果（领导力、领导、领、导、力）都要能够全部展示出来。这里我们引入ElasticSearch结合分词插件，来实现这样的搜索功能。总结一下，就是通过一个小的需求例子，很好地实现了分词搜索，并能高亮显示关
Linux-centos7安装rabbitmq
安装并启动 RabbitMQ 后，可以使用 RabbitMQ 的命令行工具 rabbitmqctl 来管理 RabbitMQ。1、安装Erlang，RabbitMQ是使用Erlang语言编写的，所以需要先安装Erlang。需要再重启一波rabbit server。才能进入127.0.0.1:1567
（五）「消息队列」之 RabbitMQ 主题（使用 .NET 客户端）
基于模式（主题）接收消息
Hbase基本原理剖析
每个Region包含了表中一段RowKey区间范围内的数据，HBase的一张数据表开始只包含一个Region，随着表中数据的增多，当一个Region的大小达到容量上限后会分裂成两个Region。为了提升数据操作的效率，HBase Client会在内存中缓存“hbase:meta”和用户表Region
Hadoop 存储占用分析命令，查看 Hdfs 文件夹占用大小
兼职公司 Hadoop 运维之后，经常要解决 Hdfs 空间占用的问题，不知道哪天谁又在集群上留下一大堆缓存文件也不清掉，Hadoop 本身默认就是三副本，人一多每个人留一点结果占用了一堆的存储空间。在 Hdfs 上也支持使用 du 进行文件大小的分析，但是套用上面的模式，就会有些不兼容，所以我对这
c++实现RabbitMQ简单的生产者和消费者
基本思想：利用c++实现RabbitMQ简单的生产者和消费者
