Flink 流计算进阶:手写一套通用的 Redis/MySQL /Kafka数据源封装工具类
一、redis篇幅
1、解决痛点
1、兼容redis集群和单机
2、异步IO,通过 AsyncDataStream.unorderedWait 提升吞吐量
3、通用性,避免重复造轮子 2、代码部分
RedisClusterUtil工具类
package com.juxin.util.redis;import cn.hutool.core.util.NumberUtil;
import cn.hutool…
2026/7/29 16:53:01