问答 2023-12-10 来自:开发者社区

flink cdc 能从kafka消费数据 写到doris吗?

flink cdc 能从kafka消费数据 写到doris吗?

文章 2023-12-07 来自:开发者社区

Apache Flink消费Kafka数据时,可以通过设置`StreamTask.setInvokingTaskNumber`方法来实现限流

Apache Flink消费Kafka数据时,可以通过设置StreamTask.setInvokingTaskNumber方法来实现限流。这个方法可以设置每个并行任务消费的分区数,从而控制数据消费的速度。 以下是一个简单的示例,展示了如何在Flink的消费源中设置限流: StreamExecutionEnvironment env =...

文章 2023-12-04 来自:开发者社区

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,但是也没有输出,大家有遇到过么?

在使用Flink CDC将Kafka中的数据写入Doris时,如果没有任何错误信息但也没有输出结果,可能的原因和解决方法包括: 检查源表的元数据:确保从Kafka读取的数据列与目标Doris表的列相匹配。这包括列的数量、名称和类型。 确认数据是否正确流入Kafka:可以使用如kafka-console-consumer.sh工...

问答 2023-12-04 来自:开发者社区

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,有遇到过么?

Flink CDC中flinksql消费kafka的数据写入doris中,没报错,但是也没有输出,大家有遇到过么?

问答 2023-12-01 来自:开发者社区

flniksql(flink版本是1.17)读取kafka的数据,这种问题大家有碰到过不?

flniksql(flink版本是1.17)读取kafka的数据,发现读出来字段都是null,但是原来kafka的字都是有值的,这种问题大家有碰到过不?用streamapi读取整张表字段都正常显示

问答 2023-11-30 来自:开发者社区

Flink 从kafka中消费到数据到map里每条转换json对象太耗时,有什么好的解决办法吗?

Flink 从kafka中消费到数据到map里每条转换json对象太耗时,繁忙100%,导致source反压,这种情况有什么好的解决办法吗?

问答 2023-11-30 来自:开发者社区

Flink消费kafka数据时会自动解压缩数据,有没有什么配置,在拉取的时候不解压缩呢?

Flink消费kafka数据时会自动解压缩数据,有没有什么配置,在拉取的时候不解压缩呢?

问答 2023-11-30 来自:开发者社区

请教个问题,我想在flink消费kafka数据时,不对消费的数据进行解压缩操作有什么办法吗?

请教个问题,我想在flink消费kafka数据时,不对消费的数据进行解压缩操作有什么办法吗?我想使用这种方式来测试flink source的最大拉取速度

文章 2023-11-23 来自:开发者社区

Flink CDC读取kafka中的数据,发现读出来数据都是都是null

遇到读取 Kafka 数据都为空的情况,请检查以下几个方面: Kafka topic 是否正确配置,确保 topic 名称、消费者组和其他属性正确无误。Kafka topic 内容是否存在有效数据。配置连接和 consumer 参数是否正确,例如 hostname、port 等。使用调试工具检查 Kafka producer 端࿰...

问答 2023-11-22 来自:开发者社区

Flink CDC 我flink 读取kafka数据然后入库到starrocks不知道问题出在哪了?

Flink CDC 各位我flink 读取kafka数据然后入库到starrocksCREATE TABLE mall_activity ( id bigint, create_time TIMESTAMP, create_by bigint, create_by_name ...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等