flinksql云消息队列 Kafka 版的相关内容

问答 2024-09-30 来自：开发者社区

flinksql写kafka，有时输出数据连续，有时却不连续？？

flinksql写kafka，开启了Checkpoint，并且设置了CheckpointingMode.EXACTLY_ONCE，写入kafka时没有设置kafka事务，为啥有时出现连续写入数据到kafka（如图1），有时又是周期性写入kafka（如图2）（周期性为Checkpoint的时间间隔）？图1 图2 sink kafka 表是： create table dwd_spyw_aler.....

问答 2024-08-26 来自：开发者社区

flinksql消费kafka然后look up join doris纬表，出现下面问题怎么解决？

flinksql消费kafka然后look up join doris纬表，最后写入doris，在look up那里反压100%啊，这种情况怎么破

问答 2024-08-19 来自：开发者社区

在机器学习PAI中，有没有用flinkSQL直接连kafka的？

问答 2024-07-31 来自：开发者社区

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到这个字段？

flinksql cdc 是不是只有从mysql同步到kafka 才能截取到op before after字段？

问答 2024-07-31 来自：开发者社区

如果用flinksql的方式同步mysql数据到kafka，是类似DTS那样吗？

如果用flinksql的方式同步mysql数据到kafka，是类似DTS那样只要数据变更有binlog就会往kafka投递消息么？

问答 2024-06-04 来自：开发者社区

flinksql 读取kafka数据写入到mysql 按照主键更新会不会导致数据乱序？

flinksql 读取kafka数据写入到mysql 按照主键更新如果上游并行度是3 再mysql ddl中设置sink.parallelism=2 会不会导致数据乱序啊哪位大佬知道？还有就是 flinksql 有办法实现keyby么。控制按照哪个字段分区？

问答 2024-05-01 来自：开发者社区

Flink CDC里flinksql如何接受kafka中value是[{},{}]格式的数据？

Flink CDC里请问谁知道flinksql如何接受kafka中value是[{},{}]格式的数据？

问答 2024-04-11 来自：开发者社区

flinksql kafka连接器可以设置source并行度吗？

问答 2024-03-27 来自：开发者社区

FlinkSql在进行窗口聚合的时候，出现无数据情况，kafka消息频率每秒50条

大佬们，求助，使用的版本1.13，建表如下图中，但是聚合的时候：SELECT window_start, window_end, COUNT(data) as num FROM TABLE(TUMBLE(TABLE line_kafka_source, DESCRIPTOR(event_time), INTERVAL '10' SECOND)) GROUP BY window_start,.....

问答 2024-01-17 来自：开发者社区