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

sink到kafka的教程有么有?

sink到kafka的教程有么有?

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

请问下,sink还没有成功,执行checkpoint会把这条数据的offset提交到kafka吗?会

请问下,sink还没有成功,执行checkpoint会把这条数据的offset提交到kafka吗?会不会存在还没sink成功,但已经把offset提上去了的情况呢?

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

各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以

各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以指定输出 schema 信息嘛? 看到好像只有 api 中可以指定 .deserializer(new JsonDebe...

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

请问下 sink端到kafka的地址换了 还能从checkpoint重启吗

请问下 sink端到kafka的地址换了 还能从checkpoint重启吗

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

有没有小伙伴试过在sink到Kafka的时候让相同的key到Kafka同一个分区?保证相同key是有

有没有小伙伴试过在sink到Kafka的时候让相同的key到Kafka同一个分区?保证相同key是有序的

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

请教下flink消费kafka后sink算了报错了然后重试了失败后依然提交了offset,这个怎么解

请教下flink消费kafka后sink算了报错了然后重试了失败后依然提交了offset,这个怎么解决啊,有没有老铁知道的。

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

mysql的datetime类型数据sink到kafka就自动变成时间戳了,这个有什么办法解决吗?

mysql的datetime类型数据sink到kafka就自动变成时间戳了,这个有什么办法解决吗?

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

请问如何优化写入kafka sink的消息分布?

请问如何优化写入kafka sink的消息分布?

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

大佬们,我用flink接Kafka解析后存两个sink到mysql能实现不

大佬们,我用flink接Kafka解析后存两个sink到mysql能实现不

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

各位你们在使用flink sql sink数据到kafka的时候出现执行成功,但是kafka里面没有

各位你们在使用flink sql sink数据到kafka的时候出现执行成功,但是kafka里面没有数据的情况?

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

产品推荐

云消息队列

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

+关注