flink cdc DataStream api 时区问题
这里主要使用第二种方式。/*** 处理Debezium时间转换的问题* Debezium默认将MySQL中datetime类型转成UTC的时间戳({@link io.debezium.time.Timestamp }) ，时区是写死的无法更改，* 导致数据库中设置的UTC+8，到kafka中变成了多
Kafka Connect详解及应用实践
Kafka Connect是一个用于数据导入和导出的工具。它能够把多种数据源（如MySQL，HDFS等）与Kafka之间进行连接，实现数据在不同系统之间的交互以及数据的流动。扩展性：Kafka Connect支持自定义Connector，用户可以通过编写自己的Connector来实现与更多数据源进行
Kafka集群安装部署（超详细操作演示）—— Linux
Kafka集群安装部署（超详细操作演示）—— Linux
Kafka的工作原理
pull模式的不足之处在于，如果kafka没有数据，消费者会陷入空循环中，针对这一点，Kafka的消费者会在消费时传入timeout参数，如果当前Kafka中没有数据，消费者会等待一个timeout时长再返回。，会被临时踢出ISR，待该follower恢复后，follower会读取本地磁盘记录的HW
黑马头条 热点文章实时计算、kafkaStream
《黑马头条》项目采用的是SpringBoot+springcloud当下最流行的微服务为项目架构，配合spring cloud alibaba nacos作为项目的注册和配置中心。新课程采用快速开发的模式，主要解决真实企业开发的一些应用场景。深入挖掘技术和业务的解决方案，做到更加的通用，能举一反三，
kafka 3.5.0集群环境部署（使用自带的zookeeper）
注意：先把集群所有节点的zookeeper启动起来，再启动kafka。
kafka如何保障数据不丢失
自动提交：设置为enable.auto.commit为true，表示开启自动提交，自动提交会在每次调用poll时，提交上次poll时的消费位移，每次poll时，都是提交上次的offset的位移，如果是在单线程的情况，不会出现消费丢失的情况，但是对应多线程的应用来说，就有可能出现消费丢失的情况，例如我
kafka 积压消息查询
在目录下，执行下面的脚本，查询kafka积压消息。
kafka如何保证消息的有序性
软件测试常见面试题：kafka如何保证消息的有序性
ELK-日志服务【kafka-配置使用】
kafka-0110.0.0.21kafka-0210.0.0.22kafka-0310.0.0.23【2】安装kafka集群
Kafka查看消息是否堆积（服务器）
kafka消息偏移量查看
Kafka3.0.0版本——消费者（消费者组详细消费流程图解及消费者重要参数）
Kafka3.0.0版本——消费者（消费者组详细消费流程图解及消费者重要参数）
DDS与MQ对比分析
努力了那么多年,回头一望,几乎全是漫长的挫折和煎熬。对于大多数人的一生来说,顺风顺水只是偶尔,挫折、不堪、焦虑和迷茫才是主旋律。我们登上并非我们所选择的舞台,演出并非我们所选择的剧本。继续加油吧！
kafka--kafka基础概念-ISR详解
因为P1S1同步数据 可能花费 50ms P1S2可能花费60ms。当绿色P1接收到写入的数据，要同步到紫色的P1S1和P1S2。使用In Sync Replicas 也就是ISR概念。同步时间是可以设置规定时间的（容忍时间）绿色部分主要监督 紫色部分有没有超时。主要是讲 主 往 从同步中的问题。
Spring boot使用Kafka Java反序列化漏洞 CVE-2023-34040
背景：公司项目扫描到 Spring-Kafka上使用通配符模式匹配进行的安全绕过漏洞 CVE-2023-20873Spring Kafka 是 Spring 框架提供的一个库，它提供了使用 Apache Kafka 的便捷方式。Apache Kafka 是一个开源的流处理平台，主要用于构建实时数据流
分布式应用之Zookeeper和Kafka
【代码】分布式应用之Zookeeper和Kafka。
使用finksql方式将mysql数据同步到kafka中，每次只能同步一张表
使用finksql方式将mysql数据同步到kafka中，每次只能同步一张表
FlinkCDC的介绍和原理
总的来说，FlinkCDC 的原理就是通过解析 MySQL 中的 binlog，抓取到最新的增量数据，并将其转换为 Flink 支持的数据格式，然后将增量数据同步到 Flink 或者其他的计算引擎中进行处理。FlinkCDC 是阿里巴巴开源的一个基于 Flink 的分布式流式数据同步工具，它可以将
Spring Boot集成Kafka详解
Spring Boot是一个用于构建独立的、生产级的Java应用程序的框架，而Kafka是一种高吞吐量的分布式发布订阅消息系统。在本文中，我们将详细解释如何在Spring Boot项目中集成Kafka。
【Flink写出到kafka报错ClassNotFoundException】
flink写出到Kafka、jar包冲突排查
