一、准备工作✅ 1. 安装 Java JDK（Kafka 依赖 Java 运行环境）Kafka 是基于 Java 的，必须先安装 JDK。一般学到kafka的同学肯定已经安装好了JDK了，这一步我就不写了，具体可以参考其他文章。⚠️ 注意：Kafka 3.9.0 要求本地必须安装 JDK 17 或以上版本。JDK 8 和 11 已不再被官…
// IDEA运行时，也可以看到webui，一般用于本地测试 //创建带有 web uI 的本地执行环境 Configuration config =new Configuration(); config.setBoolean("web.ui.enabled&…
实战！用 Flink 打通 Kafka 到 MySQL 的数据链路，附完整代码在实时数据处理场景中，“Kafka 接收数据 + Flink 处理数据 + MySQL 存储结果” 是非常经典的架构。比如用户行为日志实时统计、订单数据实时同步等场景，都离不开这套流程。今天就带大家从零搭建这套数据链路，包含完整的依赖配置、代码实现和环境准备，新…
内存溢出的异常有很多，并且每种内存溢出都会有不同的异常信息和解决方式，下面会列出常见的几种内存溢出异常堆内存溢出java.lang.OutOfMemoryError: Java heap space原因：当堆内存不足，并且已经达到JVM设置的最大值，无法继续申请新的内存，存活的对象在堆内存中无法被回收，那么就会抛出该异常，表示堆内存溢出。…
Java.lang.OutOfMemoryError这个错误我相信大部分开发人员都有遇到过，产生该错误的原因大都出于以下原因：JVM内存过小、程序不严密，产生了过多的垃圾。导致OutOfMemoryError异常的常见原因有以下几种：内存中加载的数据量过于庞大，如一次从数据库取出过多数据；集合类中有对对象的引用，使用完后未清空，使得JVM…
导语：在现代数据处理中，Spring Boot 项目集成 Kafka 和 Flink 流处理框架是实现实时数据处理和分析的关键。本文将为您介绍具体步骤和相关代码，帮助您在项目中快速集成 Kafka 和 Flink。 &nbs…
前言当要读取kafka 中的数据时，在服务器上查看比较麻烦，数据量较大，也不是很直观。此时就需要一款简洁，使用方便的可视化工具了，嘻嘻， Offset Explorer （以前叫：kafka-Tool ） 就是一个不错的选择。一、Offset Explorer 是什么？Offset Explorer （以前叫：kafka-Tool ）：学…
CentOS7.7下源码安装3.0.3版本ModSecurity及配置策略服务器操作系统：CentOS7.7 64位 需要安装依赖环境如下：1.需要用到的软件包，推荐丢到/usr/local目录下下载链接：http://www.modsecurity.cn/practice/files/apache+modsecurity.rar2.安装…
Nginx 是一个很牛的高性能Web和反向代理服务器, 它具有有很多非常优越的特性； 在高连接并发的情况下，Nginx是Apache服务器不错的替代品，目前Web服务器调查显示Apache下降Ngnix攀升，linux下更多的服务商选择了Ngnix放弃了Apache； Nginx在美国是做虚拟主机生意的老板们经常选择的软件平台之一. 能…
1.为什么选择Apache SolrApache Solr是一个功能强大的搜索服务器，它支持REST风格API。Solr是基于Lucene的，Lucene 支持强大的匹配能力，如短语，通配符，连接，分组和更多不同的数据类型。它使用 Apache Zookeeper特别针对高流量进行优化。Apache Solr提供各式各…