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

Flink CDC这种报错是需要把kafka的分区增加还是怎么样?

Flink CDC这种报错是需要把kafka的分区增加还是怎么样。(我的问题,flink消费kafka的数据,然后发现flink的webui界面只数据量远远小于实际的)?2023-10-25 16:50:10 ERROR (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:handle) - [Consume...

问答 2023-07-26 来自:开发者社区

"Flink CDC中这个报错有遇到过吗?读取MySQL的数据和Kafka有什么关系?

"Flink CDC中这个报错有遇到过吗?读取MySQL的数据和Kafka有什么关系?怎么会报一个Kafka的类型问题?这张源表给的是decimal类型,但是看changelog的default 值是一个string。 "

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

产品推荐

消息队列

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

+关注