2024年4月11日 - 在本文的第一部分中,我将描述如何将配置数据发送到 Flink集群。我们需要配置很多东西:方法参数、配置文件、机器学习模型。Flink提供了几种不同的方法,...

2024年7月12日 - flink的业务逻辑代码导致的flink反压,进而导致kafka数据挤压 .背景:通过flink程序消费kafka数据,然后数据经过flink-cdc读进来的维度数据做成状态数据,...

2024年3月24日 - flink 获取kafka key value flink获取状态数据.在Flink的检查点机制中,屏障(barrier)是划分快照(状态)的边界。在启用exactly once语义的条件下,当一个...

2024年7月1日 - 一,背景公司需要用到flink和kafka来处理大数据,对于一个没有接触过这两个东西的40岁程序员,决定自学一下,用了两天的时间终于实现了flink和kafka的对接...

2024年2月19日 - flink flink kafka flink hive flink 实时计算 flink paramtertool .flink kafka 分区没数据水位线 flink设置水位线...

手动敲命令新建topic是可以负载均衡,推测跟kafka集群配置使用不当有关系.1、查看推送程序物理机连接kafka端口6667的TCP连接,确实只有一台...blog.csdn.net