云消息队列 Kafka 版接收的相关内容

问答 2023-06-18 来自：开发者社区

请问如果flink用kafka连接器接收到数据源的结构数据，如何在导入hudi表的时候告诉hudi？

请问如果flink用kafka连接器接收到数据源的结构数据，如何在导入hudi表的时候告诉hudi某一条数据是需要删除的呢？

问答 2023-06-11 来自：开发者社区

求问各位大佬，Flink中如果数据源为kafka,每条数据格式为结构化的csv格式，把接收到的数据？

求问各位大佬，Flink中如果数据源为kafka,每条数据格式为结构化的csv格式，把接收到的数据insert到hive中，能把数据源的更新和删除同步到hive吗？如何告诉flink这条数据流是insert、update还是delete么？

问答 2023-05-04 来自：开发者社区

使用kafka接收消息时，报InvalidProtocolBufferException$Inval

使用的版本 1.1.3 drop table以后，运行CanalKafkaClientExample，报如下错误： 2019-08-20 09:22:50.159 [Thread-1] ERROR c.a.otter.canal.example.kafka.CanalKafkaClientExample - Error deserializing key/value for partition ....

问答 2023-05-04 来自：开发者社区

关于 cannal kafka 接收到的json 缺少 before

版本: canal v1.1.1 我在 client 模式下我可以获取一条数据更新前的json 和更新后的json，当我引入 cannal kafka 传输过来的json 字符串无法看到更新前json 相关内容，我这是属于正常的吗。返回的json 如下 { "data": [ { "ID": "8419", "CAR_CODE": "FZJN00008419", "CREATED_BY":....

问答 2023-02-27 来自：开发者社区

flink接收kafka消息，kafka和flink什么场景下会丢消息啊？

问答 2023-02-27 来自：开发者社区

finkcdc用了kafka吗，还是说我要自己弄一个kafka集群来接收数据？

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

Flink 我在sql cli执行连接kafka建表sql（该kafka接收csv数据），然后有一条

Flink 我在sql cli执行连接kafka建表sql（该kafka接收csv数据），然后有一条数据造的不符合字段格式，导致报错，然后该flink作业就无法继续running了，请问该如何处理呢？

文章 2022-10-13 来自：开发者社区

【kafka问题】记一次kafka消费者未接收到消息问题

作者：石臻臻, CSDN博客之星Top5、Kafka Contributor 、nacos Contributor、华为云 MVP ,腾讯云TVP, 滴滴Kafka技术专家、KnowStreaming。KnowStreaming 是滴滴开源的Kafka运维管控平台, 有兴趣一起参与参与开发的同学,但是怕自己能力不够的同学,可以联系我,当你导师带你参与开源！。出现了这样一个问题, A....