问答 2024-08-13 来自:开发者社区

B站Kafka动态sink功能如何保证数据一致性?

B站Kafka动态sink功能如何保证数据一致性?

问答 2024-08-13 来自:开发者社区

B站Kafka动态sink功能的实现原理是什么?

B站Kafka动态sink功能的实现原理是什么?

问答 2024-08-13 来自:开发者社区

B站为什么需要开发Kafka动态sink功能?

B站为什么需要开发Kafka动态sink功能?

问答 2024-08-13 来自:开发者社区

B站是如何解决Kafka动态sink问题的?

B站是如何解决Kafka动态sink问题的?

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之配置了最大连续失败数不为1,在Kafka的精准一次sink中,如果ck失败了,这批数据是否会丢失

问题一:Flink如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了 我这批数据会丢失吗? Flink中kafka 的精准一次 sink 如果我配置了最大连续失败数不为 1 那么如果我 ck 失败了 我这批数据会丢失吗? 参考答案: 如果你配置了最大连续失败数不为1,那么在Flink中Kafka的精准一次sink中,如果ck失败了,这批数据不...

实时计算 Flink版产品使用问题之配置了最大连续失败数不为1,在Kafka的精准一次sink中,如果ck失败了,这批数据是否会丢失
问答 2024-07-03 来自:开发者社区

Flink的作业为啥kafka的消息没有sink到ADB?

Flink的作业为啥kafka的消息没有sink到ADB?

问答 2024-06-05 来自:开发者社区

mongo source cdc + kafka sink connector这个组合支持吗?

在Flink CDC中mongo source cdc + kafka sink connector这个组合支持Exactly Once语义吗?

问答 2024-05-20 来自:开发者社区

Flink CDC里遇到过SInk到Kafka的这个报错么?

Flink CDC里遇到过SInk到Kafka的这个报错么:Caused by: org.apache.kafka.common.errors.TimeoutException: Topic XXX not present in metadata after 60000 ms.

文章 2024-05-16 来自:开发者社区

实时计算 Flink版产品使用合集之支持sink到多分区的kafka ,还能保持有序吗

问题一:请教下Flink CDC SQL Server用户定义数据类型该怎么处理? 请教下Flink CDC SQL Server用户定义数据类型该怎么处理?目前错误提示IllegalArgumentException: The column "WARD_CODE" is referenced as PRIMARY KEY, but a matching column is n...

文章 2024-04-28 来自:开发者社区

人工智能平台PAI 操作报错合集之pyalink 1.6.1StreamOperator.fromDataframe(out_df, out_schema_str)之后直接连kafka sink会报下面的错误如何解决

问题一:请问机器学习PAI 这个错误是因为目前的project没有挂载GPU导致的吗? 请问机器学习PAI xflow not found: algo_public.easy_rec_ext这个错误是因为目前的project没有挂载GPU导致的吗? 参考答案: 这个错误提示是因为找不到名为algo_public.easy_rec_ext的算法。这可能是...

人工智能平台PAI 操作报错合集之pyalink 1.6.1StreamOperator.fromDataframe(out_df, out_schema_str)之后直接连kafka sink会报下面的错误如何解决

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

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注