Flink cdc HiveServer2 Endpoint支持select kafka表数据吗?

Flink cdc HiveServer2 Endpoint支持select kafka表数据吗?

在OceanBase数据库多个kafka消费者读取ob一张表数据如何保证不重复呀?

在OceanBase数据库多个kafka消费者读取ob一张表数据如何保证不重复呀?

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

Flink CDC中我一个流作业kafka接收到的一个表数据想跟一个固定数据集做关联 该怎么做?

Flink CDC中我一个流作业里面 我从kafka接收到的一个表数据 想跟一个固定数据集做关联 该怎么做呢 ?

Flink CDC读表数据后写kafka,消费者消费后写es;用bulk往es同步时速率较慢导致数?

Flink CDC读表数据后写kafka,消费者消费后写es;用bulk往es同步时速率较慢导致数据积压,这个有好点的解决办法么?我是这么批量往es写的 设置的同步提交,不会再存到缓存里,需要做一些处理再往es写,直接用连接器没法实现,我一会来看下,应该也是可以的,水位线那个是啥意思,不支持配置吗?

使用Flink 读取kafka Catalog 源表数据展开json写入下游hologres表示例操作

使用Flink 读取kafka Catalog 源表数据展开json写入下游hologres表示例操作

本文主要介绍如何使用Flink 读取kafka Catalog 源表数据写入下游hologres存储,并演示'json.infer-schema.flatten-nested-columns.enable参数,递归的展开JSON中的嵌套列的效果。一 准备工作本文测试使用 阿里云消息队列Kafka版进...

请问将binlog的数据同步到kafka后,怎么将数据还原成mysql表数据呢?(kafka里面是i

请问将binlog的数据同步到kafka后,怎么将数据还原成mysql表数据呢?(kafka里面是insert、update和delete的记录行)

假如kafka或者flink出了问题,导致维表数据没有分流过去,有什么监控机制吗

假如kafka或者flink出了问题,导致维表数据没有分流过去,有什么监控机制吗

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

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载