flink问题之做实时数仓sql保证分topic区有序如何解决
问题一：flink 1.10 kafka collector topic 配置pattern 请教大家，flink 1.10里面kafka connector 不能配置topic pattern，后续会支持吗？ 参考回答： 可以关注下：https://issues.apache.org/jira/b...
请教大家一个flink sql 消费kafka，开启了checkpoint。topic每个分区都是有
请教大家一个flink sql 消费kafka，开启了checkpoint。topic每个分区都是有数据，现在监控发现，flink作业在提交offset的时候，消费一段时间后，有1个partition的数据offset不提交了，但是这个partition一直有数据
flink sql如何过滤掉kafka topic中canal json格式的delete类型数据？
flink sql如何过滤掉kafka topic中canal json格式的delete类型数据？
请问如果kafka topic收到与kafka connector sql字段不符的记录，导致fli
请问如果kafka topic收到与kafka connector sql字段不符的记录，导致flink sql作业反序列化报错，该怎么办呢？
如果kafka topic收到与kafka connector sql字段不符的记录，导致flink
如果kafka topic收到与kafka connector sql字段不符的记录，导致flink sql作业反序列化报错，该怎么办呢？
大家知道 flink sql 消费kafka如何感知动态添加topic吗？ topic-patt
大家知道 flink sql 消费kafka如何感知动态添加topic吗？ topic-pattern目前用这种方式感知到了但是没有写进去数据
flink sql 配置 kafka 连锁一个多分区的topic 一直没连上也没报错，单分区的没问题
flink sql 配置 kafka 连锁一个多分区的topic 一直没连上也没报错，单分区的没问题，这个是有什么坑吗？
flink sql confluent schema avro topic注册成表
flink sql是否能够支持将confluent schema registry注册的一个avro数据格式 的topic注册成一张table? *来自志愿者整理的flink邮件归档
flink 1.11 中cdc功能中，使用flink sql来操作一个kafka topic中的多张
场景： canal解析binlog后，将db1实例内的多张表（表数据有关联）的变化发送到kafka的单topic，单分区中，从而保证有序； 若我想做数据同步至另一个mysql实例db2中，怎么用flink sql操作多张表，同时保证表与表之间有序呢？ 例如mysql实例db1中有表test, sta...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
产品推荐
社区圈子
最佳实践
