问答 2024-05-03 来自:开发者社区

实时计算 Flink版sql如何接受kafka中value是[{},{}]格式的数据?

实时计算 Flink版sql如何接受kafka中value是[{},{}]格式的数据?目前找到的全是{},一条的数据格式

问答 2024-05-01 来自:开发者社区

Flink CDC里flinksql如何接受kafka中value是[{},{}]格式的数据?

Flink CDC里请问谁知道flinksql如何接受kafka中value是[{},{}]格式的数据?

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

实时计算Flink使用kafka source的时候怎么获取到完整的value

实时计算Flink使用kafka source的时候怎么获取到完整的value

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

大佬,请教下。oracle-cdc 写入upsert-kafka 总是有一条空value ,如何解决

大佬,请教下。oracle-cdc 写入upsert-kafka 总是有一条空value ,如何解决? 使用 的 flink sql client 开发的,有没有控制属性设置?

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

各位大佬,flink sql 通过Upsert-Kafka下发更新数据有value 为null的情况

各位大佬,flink sql 通过Upsert-Kafka下发更新数据有value 为null的情况,怎么可以让null值不下发到kafka,求指点。

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

mongoshake同步bigdecimal字段到Kafka,value丢失,是什么原因呢?

mongoshake同步bigdecimal字段到Kafka,value丢失,是什么原因呢?

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

有人知道flinksql从kafka写redis,这个value值为啥只有最后一个字段吗

有人知道flinksql从kafka写redis,这个value值为啥只有最后一个字段吗

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

kafka中如何进行key序列化和value序列化?

kafka中如何进行key序列化和value序列化?

文章 2017-11-15 来自:开发者社区

Apache Samza流处理框架介绍——kafka+LevelDB的Key/Value数据库来存储历史消息+?

转自:http://www.infoq.com/cn/news/2015/02/apache-samza-top-project Apache Samza是一个开源、分布式的流处理框架,它使用开源分布式消息处理系统Apache Kafka来实现消息服务,并使用资源管理器Apache Hadoop YARN实现容错处理、处理器隔离、安全性和资源管理。近日,从Apache官方博客中得知,开源的分布式....

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

产品推荐

云消息队列

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

+关注