各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以
各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以指定输出 schema 信息嘛? 看到好像只有 api 中可以指定 .deserializer(new JsonDebeziumDeserializationSchema(true)). flink ...
各位kafka里多张表的数据 flink sql如何 分别映射不同的表呢？
各位kafka里多张表的数据 flink sql如何 分别映射不同的表呢？
请问下，我要用sql方式写入Kafka，用哪个connector呢？
请问下，我要用sql方式写入Kafka，用哪个connector呢？
大家知道 flink sql 消费kafka如何感知动态添加topic吗？ topic-patt
大家知道 flink sql 消费kafka如何感知动态添加topic吗？ topic-pattern目前用这种方式感知到了但是没有写进去数据
各位大佬，idea中测试使用FlinkCDC SQL 读取Mysql 数据写入Kafka中，代码中创
各位大佬，idea中测试使用FlinkCDC SQL 读取Mysql 数据写入Kafka中，代码中创建了checkpoint，发现每次重启Idea中FlinkCDC的代码都会全量读取Mysql数据并写入Kafka，请教一下如何以增量的方式读取Mysql数据写入Kafka呢？是不是每次重启程序都会全量...
大佬们，flink sql client实现 mysql表实时同步到hive，除了中间转kafka再
大佬们，flink sql client实现 mysql表实时同步到hive，除了中间转kafka再写hive，有没有别的方式，能一步到位。
有没有大佬帮我看下flink sql连接kafka认证kerberos的参数配置是否有误
有没有大佬帮我看下flink sql连接kafka认证kerberos的参数配置是否有误
flink sql 配置 kafka 连锁一个多分区的topic 一直没连上也没报错，单分区的没问题
flink sql 配置 kafka 连锁一个多分区的topic 一直没连上也没报错，单分区的没问题，这个是有什么坑吗？
请问一下老师们，flink SQL kafka connector中的startup mode 选择
请问一下老师们，flink SQL kafka connector中的startup mode 选择【timestamp】模式没有按照预期从指定时间戳开始取数可能是什么问题？
各位你们在使用flink sql sink数据到kafka的时候出现执行成功，但是kafka里面没有
各位你们在使用flink sql sink数据到kafka的时候出现执行成功，但是kafka里面没有数据的情况？
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
