问答 2024-07-15 来自:开发者社区

在Flink CDC中明明有创建如下,但是使用同步消费kafka中数据的时候,会显示报错?

在Flink CDC中明明有创建 Topic :tidb_tmp_sync_cdc 但是使用kafka-sync-table同步消费kafka中数据的时候,显示Could not get metadata from server?请参考图片:

问答 2024-07-15 来自:开发者社区

在Flink CDC中MySQL整库同步,Kafka Pipeline 不支持指定 分区吗?

在Flink CDC中MySQL整库同步,Kafka Pipeline 不支持指定 topic 分区 key吗?

问答 2024-07-10 来自:开发者社区

flinkcdc同步oracle到kafka刚开始加了那两个参数可以秒级监控,有经验知道怎么排查吗?

flinkcdc同步oracle到kafka刚开始加了那两个参数可以秒级监控,现在过了几周数据延迟又到几十秒和分钟级了,有兄弟有经验知道怎么排查吗(测试环境)数据都是一条一条的造的?

问答 2024-07-10 来自:开发者社区

之前flink-cdc可以正常同步oracle的数据,发现kafka没有最新数据生产了怎么办?

之前flink-cdc可以正常同步oracle的数据,但是某次异常后,flink自动重启后就不能正常同步oracle的数据了,发现kafka没有最新数据生产了?任务的状态也是正常的,一值是running的

阿里云文档 2024-07-08

Hologres实时ETL同步到Kafka

实时ETL同步任务根据来源Hologres表结构对目标Kafka的topic进行初始化,将Hologres数据实时同步至Kafka以供消费。本文为您介绍如何创建Hologres实时ETL同步到Kafka任务。

文章 2024-06-24 来自:开发者社区

后端开发Spring框架之消息介绍 同步异步 JMS AMQP MQTT Kafka介绍

消息 介绍 消息在实际生活中的应用很常见 Spring提供了一整套丰富的消息处理功能,从基础的消息传递接口到对各种消息中间件的支持,使开发者能够方便地构建消息驱动的应用程序。无论是同步还是异步消息传递,Spring都有相应的解决方案,能够满足不同场景下的需求。 同步消息 讨债 需要别人进行回应和响应 异步消息 请帖 不需要别人回应 ...

后端开发Spring框架之消息介绍 同步异步 JMS AMQP MQTT Kafka介绍
文章 2024-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之通过flink同步kafka数据进到doris,decimal数值类型的在kafka是正常显示数值,但是同步到doris表之后数据就变成了整数,该如何处理

问题一:Flink如果sink表建表字段过短,有数据不能插入,有啥策略配置能丢弃这些不合格的数据吗? Flink如果sink表建表字段过短,有数据不能插入,有啥策略配置能丢弃这些不合格的数据吗? configuration.set(ExecutionConfigOptions.TABLE_EXEC_SINK_TYPE_LENGTH_ENFORCER, ExecutionConfi...

实时计算 Flink版产品使用问题之通过flink同步kafka数据进到doris,decimal数值类型的在kafka是正常显示数值,但是同步到doris表之后数据就变成了整数,该如何处理
问答 2024-06-12 来自:开发者社区

在Flink CDC中整库同步是先将整库的所有表数据同步到一个kafka里吗?

在Flink CDC中整库同步是先将整库的所有表数据同步到一个kafka里吗?

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

在Flink CDC中配置文件同步方式,没有kafka管道jar包,怎么办?

在Flink CDC中配置文件同步方式,没有kafka管道jar包,怎么办?

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

从RDS for MySQL同步至自建Kafka集群

从RDS for MySQL同步至自建Kafka集群

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注