文章 2023-07-26 来自:开发者社区

Flink的sink实战之二:kafka

欢迎访问我的GitHub 这里分类和汇总了欣宸的全部原创(含配套源码):https://github.com/zq2599/blog_demos 本文是《Flink的sink实战》系列的第二篇,前文《Flink的sink实战之一:初探》对sink有了基本的了解,本章来体验将数据sink到kafka的操作; 版本和环境准备 本次实战的环境和版本如下: JDK:1.8.0_2...

Flink的sink实战之二:kafka
问答 2023-07-26 来自:开发者社区

flink cdc source mysql sink kafka 报包冲突 如何解决?

问题1:flink cdc source mysql sink kafka 报包冲突 如何解决?问题2:这个也看不出问题。我cdc 2.4 flink 1.13.6

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

Flink中自定义的sink 如果kafka 已经发送消息了,这个是ck会不会被认为完成。但是最终?

Flink中自定义的sink 如果kafka 已经发送消息了,这个是ck会不会被认为完成。但是最终这个消息发送失败了?

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

Flink中cdas整库同步是否支持sink段到kafka形成一个topic?目前我知道是不可以的,

Flink中cdas整库同步是否支持sink段到kafka形成一个topic?目前我知道是不可以的,不知道未来会不会这样做,那就只能用datastream接入全部数据打入kafka单topic了,加解密数据,愁死人了,加解密还不让我们来操作 看来得看看paimon

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

大佬们请教一个flink 重启生产者的问题,我通过检查点重启作业,但是sink的Kafka ?

大佬们请教一个flink 重启生产者的问题,我通过检查点重启作业,但是sink的Kafka topic换了,就一直报错说生产者尝试使用producer id,但是当前没有给其分配对应的transactional id,这个怎么解决?我通过网上了解到的 producer启动时Kafka会为其分配一个唯一的producer id,这个transactional id是我们自己手动指定的?

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

大佬们请教一个Flink CDC重启生产者的问题,我通过检查点重启作业,但是sink的Kafka ?

大佬们请教一个Flink CDC重启生产者的问题,我通过检查点重启作业,但是sink的Kafka topic换了,就一直报错说生产者尝试使用producer id,但是当前没有给其分配对应的transactional id,这个怎么解决?我通过网上了解到的 producer启动时Kafka会为其分配一个唯一的producer id,这个transactional id是我们自己手动指定的?

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

flink cdc sink kafka 作业重启 taskmanaget一直在初始化是什么原?

flink cdc sink kafka 作业重启 taskmanaget一直在初始化是什么原因?他这个tm日志一直再刷ProducerId,是是什么意思?

问答 2023-03-21 来自:开发者社区

问下大佬们就是flink upsert kafka sink 删除数据的时候是只能收到null值吗?

问下大佬们就是flink upsert kafka sink 删除数据的时候是只能收到null值吗,那这种的话我这边如何判断是删除了哪条数据呢?

问答 2023-03-13 来自:开发者社区

请问下 使用Flink CDC 写入kafka 为什么没有sink的图呢?

请问下 使用Flink CDC 读取mysql Flink SQL 方式写入kafka的时候 为什么没有sink的图呢?

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

请教一下sink Kafka的时候,会按主键分区吗?

请教一下sink Kafka的时候,会按主键分区吗?

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

产品推荐

云消息队列

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

+关注