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

请问flink cdc 有没有办法,通过sql的方式,将整库的binlog写到kafka呢?

请问flink cdc 有没有办法,通过sql的方式,将整库的binlog写到kafka呢?

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

有没有办法删除 debezium 的 在kafka上存储的history重新建立这个同名连接?

有没有办法尚删除 debezium 的 在kafka上存储的history主题后,重新建立这个同名的连接,不报错 io.debezium.DebeziumException: The db history topic is missing. You may attempt to recover it by reconfiguring the connector to SCHEM...

问答 2021-12-06 来自:开发者社区

有没有啥办法,可以直接从table_ddl中取最新的kafka数据呢?

各位大佬好,请教一个问题: 利用kafka作为流式源,注册内部的flink的动态表,如下面的table_ddl ,是否由于'update-mode' = 'append',所以随着kafka消息逐步的推送,会导致table_ddl这个表的数据不断在增大,但是我想要的是kafka每推送一条数据,table_ddl就会相应的是这一条数据,请问这个如何实现呢?(或者有没有啥办法,可以直接从ta...

问答 2019-11-28 来自:开发者社区

有没有办法找出Kafka进行数据序列化所花费的时间

我想计时卡夫卡序列化不同数据格式所花费的时间。并且怀疑我是否可以这样做(因为我认为这是在Kafka方面完成的。)如果是,我们该怎么做?在message.send()之后进行序列化吗?另外,我还在检查可用的Kafka监控指标,也没有在他们的文档中找到与此相关的任何内容。曾将request-latency-avg视为一种可能的指标,但它的值似乎太高,无法仅作为序列化部分。任何人都可以建议相同的东西。

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

产品推荐

云消息队列

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

+关注
AI助理

你好,我是AI助理

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