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

问答 2022-09-15 来自：开发者社区

如果kafka一直没有数据到来，flink是不是什么计算都触发不了？

onTimer能触发吗

问答 2022-07-03 来自：开发者社区

flinksql是可以直接客户端建表读mysql或是kafka数据，但是怎么让它自动流转计算起来呢？

flinksql是可以直接客户端建表读mysql或是kafka数据，但是怎么让它自动流转计算起来呢？一定要写java或python代码去实现么？

文章 2022-04-20 来自：开发者社区

基于Kafka connect+函数计算的轻量计算解决方案

kafka ETL架构解析基于Kafka connect+函数计算的轻量计算解决方案——竹恩消息队列Kafka产品研发专家KafkaETL基于kafkaconnect加函数计算，为云上用户提供了一套数据流转加数据计算的一站式解决方案。一、问题背景在大数据云计算时代，一个复杂的大型系统一般都是由许多处理特定任务的子系统构成，各个子系统由不同的团队开发，因此各个系统在数据、数据的格式和内容上会存在天....

问答 2022-02-15 来自：开发者社区

Debezium+Kafka+计算程序+存储系统这种方案有什么难度？

问答 2022-02-15 来自：开发者社区

Debezium+Kafka+计算程序+存储系统架构图是什么样的？

问答 2022-02-15 来自：开发者社区

kafka Streams中用什么来表示流处理应用程序进行数据处理的计算逻辑？

问答 2022-02-15 来自：开发者社区

flink中Kafka流表关联HBase维度表的计算逻辑是什么呢？

问答 2022-02-15 来自：开发者社区

如何通过Flink-sql 实现3个kafka-topic的join以及后续的窗口聚合计算操作？

同行们，大家好，请教一个问题，现在有3个kafka的topic：device consumer order 想用Flink-sql计算出多个聚合指标，比如：过去12小时，每个deviceid下的订单量。我是这么设计的：先通过 create table with(...='kafka') ... 注册出 table1 table2 table3 ，指定事件时间、water mark...

问答 2021-12-08 来自：开发者社区

flinksql1.11 使用eventime消费kafka多分区时,没有水位线信息,聚合计算也不出

大佬好,我在1.11版本测试flink sql时发现一个问题,用streaming api 消费kafka,使用eventtime,再把stream转table,进行sql聚合,发现当kafka topic是多个分区时,flink webui watermarks 显示No Watermark,聚合计算也迟迟不触发计算,但当kafka topic只有一个分区时却能这个正常触发计算,waterma....

问答 2021-12-08 来自：开发者社区