2024年5月24日 - 哪位大哥有flink 读取kafka sink到hbase 的生产代码吗.那位大神,给一个java版的flink1.7 读取kafka数据,做实时监控和统计的功能的代码案例...

2024年5月24日 - Flink1.18.0版本连接外部kafka本地执行测试代码报错 版本:Flink1.18.0代码如下:~~~public static void main(String args) { //1、创建TableEnvironmen...

2024年12月13日 - 在处理Flink和Kafka的数据异常时,可以采取以下策略:### Flink中的数据异常处理- **自定义异常处理器**:通过实现~AsyncFunction~接口创建异步函数,定义...

2024年10月8日 - flinkkafkasink分区flinkkafka consumer.flinkKafkaSinkpartition 配置flinkkafka consumer...

2024年5月23日 - 1.15版本的flink往kafka多个topic写消息,是自定义实现KafkaSerializat.flink任务,连接多个 kafka的 topic作为数据源,报类型转换异常...

2024年5月23日 - 请教大家一个flink sql 消费kafka,开启了checkpoint.topic每个分区都是有数据,现在监控发现,flink作业在提交offset的时候,消费一段时间后,有1个partit...